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

Fix flaky test_keeper_snapshots

Browse Source
This commit is contained in:
Antonio Andelic 2023-04-05 08:56:01 +00:00
parent e428ed5543
commit f7586e38ed
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
tests/integration/test_keeper_snapshots/test.py
View File

@ -57,9 +57,10 @@ def restart_clickhouse():
def test_state_after_restart(started_cluster): def test_state_after_restart(started_cluster):
try: keeper_utils.wait_until_connected(started_cluster, node)
node_zk = None node_zk = None
node_zk2 = None node_zk2 = None
try:
node_zk = get_connection_zk("node") node_zk = get_connection_zk("node")
node_zk.create("/test_state_after_restart", b"somevalue") node_zk.create("/test_state_after_restart", b"somevalue")
@ -108,9 +109,10 @@ def test_state_after_restart(started_cluster):
def test_ephemeral_after_restart(started_cluster): def test_ephemeral_after_restart(started_cluster):
try: keeper_utils.wait_until_connected(started_cluster, node)
node_zk = None node_zk = None
node_zk2 = None node_zk2 = None
try:
node_zk = get_connection_zk("node") node_zk = get_connection_zk("node")
session_id = node_zk._session_id session_id = node_zk._session_id