diff --git a/tests/integration/test_parallel_replicas_protocol/test.py b/tests/integration/test_parallel_replicas_protocol/test.py index 65b2ab00043..c43226c5ecc 100644 --- a/tests/integration/test_parallel_replicas_protocol/test.py +++ b/tests/integration/test_parallel_replicas_protocol/test.py @@ -68,5 +68,7 @@ def test_mark_segment_size_communicated_correctly(start_cluster): ) nodes[0].query("SYSTEM FLUSH LOGS") - log_line = nodes[0].grep_in_log(f"{query_id}.*Reading state is fully initialized") + log_line = nodes[0].grep_in_log( + f"{query_id}.*Reading state is fully initialized" + ) assert re.search(r"mark_segment_size: (\d+)", log_line).group(1) == "16384"