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

Fix startup test

Browse Source
This commit is contained in:
Chebarykov Pavel 2022-06-02 09:09:24 +00:00
parent a4b2bdd6c8
commit 6353b58b6a
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
tests/integration/test_storage_nats/test.py
View File

@ -1297,14 +1297,14 @@ def test_nats_no_connection_at_startup_2(nats_cluster):
SELECT * FROM test.cs;
"""
)
while not check_table_is_ready(instance, "test.cs"):
logging.debug("Table test.cs is not yet ready")
time.sleep(0.5)
instance.query("DETACH TABLE test.cs")
nats_cluster.pause_container("nats1")
instance.query("ATTACH TABLE test.cs")
nats_cluster.unpause_container("nats1")
while not check_table_is_ready(instance, "test.cs"):
logging.debug("Table test.cs is not yet ready")
time.sleep(0.5)
messages_num = 1000
messages = []
@ -1312,7 +1312,7 @@ def test_nats_no_connection_at_startup_2(nats_cluster):
messages.append(json.dumps({"key": i, "value": i}))
asyncio.run(nats_produce_messages(nats_cluster.nats_ip, "cs", messages))
while True:
for _ in range(20):
result = instance.query("SELECT count() FROM test.view")
time.sleep(1)
if int(result) == messages_num: