This commit is contained in:
alesapin 2020-04-20 18:17:34 +03:00
parent 1bc84ec8b4
commit e1fa39d801

View File

@ -59,5 +59,5 @@ def test_replica_always_download(started_cluster):
node1_parts = node1.query("SELECT COUNT() FROM system.parts WHERE table = 'test_table' and active=1").strip() node1_parts = node1.query("SELECT COUNT() FROM system.parts WHERE table = 'test_table' and active=1").strip()
node2_parts = node2.query("SELECT COUNT() FROM system.parts WHERE table = 'test_table' and active=1").strip() node2_parts = node2.query("SELECT COUNT() FROM system.parts WHERE table = 'test_table' and active=1").strip()
assert node1_parts < '10' # something merged assert int(node1_parts) < 10 # something merged
assert node2_parts < '10' assert int(node2_parts) < 10