Update test.py

This commit is contained in:
Alexander Tokmakov 2023-07-26 00:01:46 +03:00 committed by GitHub
parent d7de8bf797
commit 20300804b1
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -55,16 +55,7 @@ def test_shutdown_and_wait(start_cluster):
node1.query(f"INSERT INTO test_table VALUES ({value})")
with PartitionManager() as pm:
assert node2.query("SELECT * FROM test_table") == "0\n"
pm.partition_instances(node1, node2)
# iptables rules must be applied immediately, but looks like sometimes they are not...
assert_eq_with_retry(
node1,
"select count() from remote('node1,node2', 'system.one')",
"1\n",
settings={"skip_unavailable_shards": 1},
)
p.map(insert, range(1, 50))
# Start shutdown async