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

Fix test_replica_is_active flaky test

Browse Source
This commit is contained in:
alesapin 2022-01-23 19:31:09 +03:00
parent d4d4531dea
commit 51a6d08bff
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
tests/integration/test_replica_is_active/test.py
View File

@ -1,6 +1,7 @@
import pytest
from helpers.client import QueryRuntimeException
from helpers.cluster import ClickHouseCluster
from ast import literal_eval
cluster = ClickHouseCluster(__file__)
node1 = cluster.add_instance('node1', with_zookeeper=True)
@ -30,12 +31,12 @@ def start_cluster():
def test_replica_is_active(start_cluster):
query_result = node1.query("select replica_is_active from system.replicas where table = 'test_table'")
assert query_result == '{\'node1\':1,\'node2\':1,\'node3\':1}\n'
assert literal_eval(query_result) == {'node1': 1, 'node2': 1, 'node3': 1}
node3.stop()
query_result = node1.query("select replica_is_active from system.replicas where table = 'test_table'")
assert query_result == '{\'node1\':1,\'node2\':1,\'node3\':0}\n'
assert literal_eval(query_result) == {'node1': 1, 'node2': 1, 'node3': 0}
node2.stop()
query_result = node1.query("select replica_is_active from system.replicas where table = 'test_table'")
assert query_result == '{\'node1\':1,\'node2\':0,\'node3\':0}\n'
assert literal_eval(query_result) == {'node1': 1, 'node2': 0, 'node3': 0}