diff --git a/ch_backup/clickhouse/metadata_cleaner.py b/ch_backup/clickhouse/metadata_cleaner.py index d58ca5a..d9c2ec2 100644 --- a/ch_backup/clickhouse/metadata_cleaner.py +++ b/ch_backup/clickhouse/metadata_cleaner.py @@ -123,7 +123,7 @@ def clean_database_metadata(self, replicated_databases: List[Database]) -> None: path_resolved, ) future = self._exec_pool.submit( - self._ch_ctl.system_drop_database_replica, self._replica_to_drop, path_resolved # type: ignore + self._ch_ctl.system_drop_database_replica, full_replica_name, path_resolved # type: ignore ) tasks[f"{database.name}"] = future