fix test_kafka_no_holes_when_write_suffix_failed

CheSema · CheSema · commit 64e58ef3505a · 2025-05-15T16:18:09.000+02:00
diff --git a/tests/integration/test_storage_kafka/test_batch_fast.py b/tests/integration/test_storage_kafka/test_batch_fast.py
@@ -2284,7 +2284,7 @@ def test_kafka_no_holes_when_write_suffix_failed(kafka_cluster, create_query_gen
         with PartitionManager() as pm:
             pm.drop_instance_zk_connections(instance)
             instance.wait_for_log_line(
-                "Error.*(Connection loss|Coordination::Exception).*while pushing to view",
+                "Error.*(Connection loss|Coordination::Exception|DB::Exception: Coordination error: Operation timeout).*while pushing to view",
                 timeout=60,
                 look_behind_lines=500
             )

Original file line number	Diff line number	Diff line change
`@@ -2284,7 +2284,7 @@ def test_kafka_no_holes_when_write_suffix_failed(kafka_cluster, create_query_gen`
`2284`	`2284`	`with PartitionManager() as pm:`
`2285`	`2285`	`pm.drop_instance_zk_connections(instance)`
`2286`	`2286`	`instance.wait_for_log_line(`
`2287`		`- "Error.(Connection loss\|Coordination::Exception).while pushing to view",`
	`2287`	`+ "Error.(Connection loss\|Coordination::Exception\|DB::Exception: Coordination error: Operation timeout).while pushing to view",`
`2288`	`2288`	`timeout=60,`
`2289`	`2289`	`look_behind_lines=500`
`2290`	`2290`	`)`