Add unpause container after test

This commit is contained in:
kssenii 2021-04-03 07:59:26 +00:00
parent 2de6b99f84
commit fdab1021f6
2 changed files with 2 additions and 0 deletions

View File

@ -256,6 +256,7 @@ def test_mysql_distributed(started_cluster):
# disconnect mysql1 # disconnect mysql1
started_cluster.pause_container('mysql1') started_cluster.pause_container('mysql1')
result = node2.query("SELECT DISTINCT(name) FROM test_shards ORDER BY name") result = node2.query("SELECT DISTINCT(name) FROM test_shards ORDER BY name")
started_cluster.unpause_container('mysql1')
assert(result == 'host2\nhost4\n' or result == 'host3\nhost4\n') assert(result == 'host2\nhost4\n' or result == 'host3\nhost4\n')

View File

@ -289,6 +289,7 @@ def test_postgres_distributed(started_cluster):
# Disconnect postgres1 # Disconnect postgres1
started_cluster.pause_container('postgres1') started_cluster.pause_container('postgres1')
result = node2.query("SELECT DISTINCT(name) FROM test_shards ORDER BY name") result = node2.query("SELECT DISTINCT(name) FROM test_shards ORDER BY name")
started_cluster.unpause_container('postgres1')
assert(result == 'host2\nhost4\n' or result == 'host3\nhost4\n') assert(result == 'host2\nhost4\n' or result == 'host3\nhost4\n')