Update test.py

This commit is contained in:
Nikita Mikhaylov 2021-06-07 13:06:41 +03:00 committed by GitHub
parent b99350b50d
commit 652de7c9b0
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -320,8 +320,14 @@ class Task_self_copy:
def execute_task(started_cluster, task, cmd_options):
task.start()
zk = cluster.get_kazoo_client('zoo1')
zk = started_cluster.get_kazoo_client('zoo1')
print("Use ZooKeeper server: {}:{}".format(zk.hosts[0][0], zk.hosts[0][1]))
try:
zk.delete("/clickhouse-copier", recursive=True)
except kazoo.exceptions.NoNodeError:
print("No node /clickhouse-copier. It is Ok in first test.")
# Run cluster-copier processes on each node
docker_api = started_cluster.docker_client.api