thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-22 07:31:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

Review fix

Browse Source
This commit is contained in:
alesapin 2022-06-07 16:09:21 +02:00
parent b459e33892
commit 278e7722ed
1 changed files with 12 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
tests/integration/test_keeper_zookeeper_converter/test.py
View File

@ -221,6 +221,16 @@ def get_bytes(s):
return s.encode() return s.encode()
def assert_ephemeral_disappear(connection, path):
for _ in range(200):
if not connection.exists(path):
break
time.sleep(0.1)
else:
raise Exception("ZK refuse to remove ephemeral nodes")
@pytest.mark.parametrize(("create_snapshots"), [True, False]) @pytest.mark.parametrize(("create_snapshots"), [True, False])
def test_simple_crud_requests(started_cluster, create_snapshots): def test_simple_crud_requests(started_cluster, create_snapshots):
restart_and_clear_zookeeper() restart_and_clear_zookeeper()
@ -265,13 +275,7 @@ def test_simple_crud_requests(started_cluster, create_snapshots):
fake_connection = get_fake_zk(timeout=5) fake_connection = get_fake_zk(timeout=5)
for conn in [genuine_connection, fake_connection]: for conn in [genuine_connection, fake_connection]:
for i in range(200): assert_ephemeral_disappear(conn, "/test_ephemeral/0")
if not conn.exists("/test_ephemeral/0"):
break
time.sleep(0.1)
else:
raise Exception("ZK refuse to remove ephemeral nodes")
# After receiving close request zookeeper updates pzxid of ephemeral parent. # After receiving close request zookeeper updates pzxid of ephemeral parent.
# Keeper doesn't receive such request (snapshot created before it) so it doesn't do it. # Keeper doesn't receive such request (snapshot created before it) so it doesn't do it.
@ -353,13 +357,7 @@ def test_multi_and_failed_requests(started_cluster, create_snapshots):
fake_connection = get_fake_zk(timeout=5) fake_connection = get_fake_zk(timeout=5)
for conn in [genuine_connection, fake_connection]: for conn in [genuine_connection, fake_connection]:
for i in range(200): assert_ephemeral_disappear(conn, "/test_multitransactions/fred0")
if not conn.exists("/test_multitransactions/fred0"):
break
time.sleep(0.1)
else:
raise Exception("ZK refuse to remove ephemeral nodes")
# After receiving close request zookeeper updates pzxid of ephemeral parent. # After receiving close request zookeeper updates pzxid of ephemeral parent.
# Keeper doesn't receive such request (snapshot created before it) so it doesn't do it. # Keeper doesn't receive such request (snapshot created before it) so it doesn't do it.