thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-19 16:20:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

better test_keeper_broken_logs

Browse Source
This commit is contained in:
Antonio Andelic 2023-11-16 13:05:37 +00:00
parent 8fe093c355
commit bdf038191a
1 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
tests/integration/test_keeper_broken_logs/test.py
View File

@ -1,13 +1,7 @@
import pytest
from helpers.cluster import ClickHouseCluster
import helpers.keeper_utils as keeper_utils
import random
import string
import os
import time
from multiprocessing.dummy import Pool
from helpers.network import PartitionManager
from helpers.test_tools import assert_eq_with_retry
cluster = ClickHouseCluster(__file__)
node1 = cluster.add_instance(
@ -82,6 +76,13 @@ def test_single_node_broken_log(started_cluster):
node1_conn.close()
node1.stop_clickhouse()
# wait until cluster stabilizes with a new leader
while not keeper_utils.is_leader(
started_cluster, node2
) and not keeper_utils.is_leader(started_cluster, node3):
time.sleep(1)
node1.exec_in_container(
[
"truncate",