diff --git a/dbms/tests/integration/test_ttl_move/test.py b/dbms/tests/integration/test_ttl_move/test.py index b4dbff6fa5c..2312c0cdfad 100644 --- a/dbms/tests/integration/test_ttl_move/test.py +++ b/dbms/tests/integration/test_ttl_move/test.py @@ -69,7 +69,7 @@ def test_inserts_to_disk_work(started_cluster, name, engine): used_disks = get_used_disks_for_table(node1, name) assert set(used_disks) == {"external"} - assert node1.query("SELECT count() FROM {}".format(name=name)).strip() == 10 + assert node1.query("SELECT count() FROM {}".format(name=name)).strip() == "10" finally: node1.query("DROP TABLE IF EXISTS {}".format(name)) @@ -99,7 +99,7 @@ def test_inserts_to_disk_do_not_work(started_cluster, name, engine): used_disks = get_used_disks_for_table(node1, name) assert set(used_disks) == {"jbod1"} - assert node1.query("SELECT count() FROM {}".format(name=name)).strip() == 10 + assert node1.query("SELECT count() FROM {}".format(name=name)).strip() == "10" finally: node1.query("DROP TABLE IF EXISTS {}".format(name)) @@ -133,7 +133,7 @@ def test_moves_to_disk_work(started_cluster, name, engine): used_disks = get_used_disks_for_table(node1, name) assert set(used_disks) == {"external"} - assert node1.query("SELECT count() FROM {}".format(name=name)).strip() == 10 + assert node1.query("SELECT count() FROM {}".format(name=name)).strip() == "10" finally: node1.query("DROP TABLE IF EXISTS {}".format(name)) @@ -167,7 +167,7 @@ def test_moves_to_disk_do_not_work(started_cluster, name, engine): used_disks = get_used_disks_for_table(node1, name) assert set(used_disks) == {"jbod1"} - assert node1.query("SELECT count() FROM {}".format(name=name)).strip() == 10 + assert node1.query("SELECT count() FROM {}".format(name=name)).strip() == "10" finally: node1.query("DROP TABLE IF EXISTS {}".format(name)) @@ -205,7 +205,7 @@ def test_moves_to_volume_work(started_cluster, name, engine): used_disks = get_used_disks_for_table(node1, name) assert set(used_disks) == {"external"} - assert node1.query("SELECT count() FROM {}".format(name=name)).strip() == 20 + assert node1.query("SELECT count() FROM {}".format(name=name)).strip() == "20" finally: node1.query("DROP TABLE IF EXISTS {}".format(name)) @@ -239,7 +239,7 @@ def test_inserts_to_volume_work(started_cluster, name, engine): used_disks = get_used_disks_for_table(node1, name) assert set(used_disks) == {"external"} - assert node1.query("SELECT count() FROM {}".format(name=name)).strip() == 20 + assert node1.query("SELECT count() FROM {}".format(name=name)).strip() == "20" finally: node1.query("DROP TABLE IF EXISTS {}".format(name)) @@ -293,7 +293,7 @@ def test_moves_to_disk_eventually_work(started_cluster, name, engine): used_disks = get_used_disks_for_table(node1, name) assert set(used_disks) == {"jbod2"} - assert node1.query("SELECT count() FROM {}".format(name=name)).strip() == 10 + assert node1.query("SELECT count() FROM {}".format(name=name)).strip() == "10" finally: node1.query("DROP TABLE IF EXISTS {}".format(name_temp)) @@ -339,7 +339,7 @@ def test_merges_to_disk_work(started_cluster, name, engine): assert set(used_disks) == {"external"} assert "1" == node1.query("SELECT count() FROM system.parts WHERE table = '{}' AND active = 1".format(name)).strip() - assert node1.query("SELECT count() FROM {}".format(name=name)).strip() == 16 + assert node1.query("SELECT count() FROM {}".format(name=name)).strip() == "16" finally: node1.query("DROP TABLE IF EXISTS {}".format(name)) @@ -399,7 +399,7 @@ def test_merges_to_full_disk_work(started_cluster, name, engine): assert set(used_disks) == {"jbod1"} # Merged to the same disk against the rule. assert "1" == node1.query("SELECT count() FROM system.parts WHERE table = '{}' AND active = 1".format(name)).strip() - assert node1.query("SELECT count() FROM {}".format(name=name)).strip() == 16 + assert node1.query("SELECT count() FROM {}".format(name=name)).strip() == "16" finally: node1.query("DROP TABLE IF EXISTS {}".format(name_temp)) @@ -438,7 +438,7 @@ def test_moves_after_merges_work(started_cluster, name, engine): used_disks = get_used_disks_for_table(node1, name) assert set(used_disks) == {"external"} - assert node1.query("SELECT count() FROM {}".format(name=name)).strip() == 16 + assert node1.query("SELECT count() FROM {}".format(name=name)).strip() == "16" finally: node1.query("DROP TABLE IF EXISTS {}".format(name)) @@ -483,7 +483,7 @@ def test_merges_to_disk_do_not_work(started_cluster, name, engine): assert set(used_disks) == {"jbod1"} assert "1" == node1.query("SELECT count() FROM system.parts WHERE table = '{}' AND active = 1".format(name)).strip() - assert node1.query("SELECT count() FROM {}".format(name=name)).strip() == 16 + assert node1.query("SELECT count() FROM {}".format(name=name)).strip() == "16" finally: node1.query("DROP TABLE IF EXISTS {}".format(name)) @@ -522,7 +522,7 @@ def test_moves_after_merges_do_not_work(started_cluster, name, engine): used_disks = get_used_disks_for_table(node1, name) assert set(used_disks) == {"jbod1"} - assert node1.query("SELECT count() FROM {}".format(name=name)).strip() == 16 + assert node1.query("SELECT count() FROM {}".format(name=name)).strip() == "16" finally: node1.query("DROP TABLE IF EXISTS {}".format(name))