diff --git a/tests/integration/test_ddl_worker_replicas/test.py b/tests/integration/test_ddl_worker_replicas/test.py index 28ec558df31..fecb7d97d25 100644 --- a/tests/integration/test_ddl_worker_replicas/test.py +++ b/tests/integration/test_ddl_worker_replicas/test.py @@ -59,10 +59,10 @@ def test_ddl_worker_replicas(started_cluster): # wait for node4 active path is removed node1.query_with_retry( - sql = f"SELECT count() FROM system.zookeeper WHERE path='/clickhouse/task_queue/replicas/node4:9000'", - check_callback= lambda result: result == 0, + sql=f"SELECT count() FROM system.zookeeper WHERE path='/clickhouse/task_queue/replicas/node4:9000'", + check_callback=lambda result: result == 0, ) - + result = node1.query_with_retry( f"SELECT name, value, ephemeralOwner FROM system.zookeeper WHERE path='/clickhouse/task_queue/replicas/node4:9000'" ).strip()