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

Fixed typos in a test.

Browse Source
This commit is contained in:
Vladimir Chebotarev 2019-11-27 22:13:37 +03:00
parent 108e2b33eb
commit b3427af0c1
1 changed files with 12 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
dbms/tests/integration/test_ttl_move/test.py
View File

@ -69,7 +69,7 @@ def test_inserts_to_disk_work(started_cluster, name, engine):
used_disks = get_used_disks_for_table(node1, name) used_disks = get_used_disks_for_table(node1, name)
assert set(used_disks) == {"external"} 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: finally:
node1.query("DROP TABLE IF EXISTS {}".format(name)) 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) used_disks = get_used_disks_for_table(node1, name)
assert set(used_disks) == {"jbod1"} 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: finally:
node1.query("DROP TABLE IF EXISTS {}".format(name)) 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) used_disks = get_used_disks_for_table(node1, name)
assert set(used_disks) == {"external"} 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: finally:
node1.query("DROP TABLE IF EXISTS {}".format(name)) 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) used_disks = get_used_disks_for_table(node1, name)
assert set(used_disks) == {"jbod1"} 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: finally:
node1.query("DROP TABLE IF EXISTS {}".format(name)) 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) used_disks = get_used_disks_for_table(node1, name)
assert set(used_disks) == {"external"} 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: finally:
node1.query("DROP TABLE IF EXISTS {}".format(name)) 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) used_disks = get_used_disks_for_table(node1, name)
assert set(used_disks) == {"external"} 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: finally:
node1.query("DROP TABLE IF EXISTS {}".format(name)) 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) used_disks = get_used_disks_for_table(node1, name)
assert set(used_disks) == {"jbod2"} 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: finally:
node1.query("DROP TABLE IF EXISTS {}".format(name_temp)) 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 set(used_disks) == {"external"}
assert "1" == node1.query("SELECT count() FROM system.parts WHERE table = '{}' AND active = 1".format(name)).strip() 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: finally:
node1.query("DROP TABLE IF EXISTS {}".format(name)) 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 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 "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: finally:
node1.query("DROP TABLE IF EXISTS {}".format(name_temp)) 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) used_disks = get_used_disks_for_table(node1, name)
assert set(used_disks) == {"external"} 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: finally:
node1.query("DROP TABLE IF EXISTS {}".format(name)) 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 set(used_disks) == {"jbod1"}
assert "1" == node1.query("SELECT count() FROM system.parts WHERE table = '{}' AND active = 1".format(name)).strip() 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: finally:
node1.query("DROP TABLE IF EXISTS {}".format(name)) 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) used_disks = get_used_disks_for_table(node1, name)
assert set(used_disks) == {"jbod1"} 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: finally:
node1.query("DROP TABLE IF EXISTS {}".format(name)) node1.query("DROP TABLE IF EXISTS {}".format(name))