Update test_5.py

kssenii · web-flow · commit b900f49708d3 · 2026-01-07T11:37:55.000+01:00
diff --git a/tests/integration/test_storage_s3_queue/test_5.py b/tests/integration/test_storage_s3_queue/test_5.py
@@ -470,6 +470,7 @@ def test_failure_in_the_middle(started_cluster):
         additional_settings={
             "keeper_path": keeper_path,
             "s3queue_loading_retries": 10000,
+            "polling_max_timeout_ms": 100,
         },
     )
     values = []
@@ -526,7 +527,7 @@ def check_failpoint():
             )
         )
     finally:
-        started_cluster.instances["instance"].query(
+        node.query(
             f"SYSTEM DISABLE FAILPOINT object_storage_queue_fail_in_the_middle_of_file"
         )
 
@@ -536,7 +537,7 @@ def get_count():
     assert 0 == get_count()
 
     processed = False
-    for _ in range(40):
+    for _ in range(50):
         node.query("SYSTEM FLUSH LOGS")
         processed = int(
             node.query(

Original file line number	Diff line number	Diff line change
`@@ -470,6 +470,7 @@ def test_failure_in_the_middle(started_cluster):`
`470`	`470`	`additional_settings={`
`471`	`471`	`"keeper_path": keeper_path,`
`472`	`472`	`"s3queue_loading_retries": 10000,`
	`473`	`+ "polling_max_timeout_ms": 100,`
`473`	`474`	`},`
`474`	`475`	`)`
`475`	`476`	`values = []`
`@@ -526,7 +527,7 @@ def check_failpoint():`
`526`	`527`	`)`
`527`	`528`	`)`
`528`	`529`	`finally:`
`529`		`- started_cluster.instances["instance"].query(`
	`530`	`+ node.query(`
`530`	`531`	`f"SYSTEM DISABLE FAILPOINT object_storage_queue_fail_in_the_middle_of_file"`
`531`	`532`	`)`
`532`	`533`
`@@ -536,7 +537,7 @@ def get_count():`
`536`	`537`	`assert 0 == get_count()`
`537`	`538`
`538`	`539`	`processed = False`
`539`		`- for _ in range(40):`
	`540`	`+ for _ in range(50):`
`540`	`541`	`node.query("SYSTEM FLUSH LOGS")`
`541`	`542`	`processed = int(`
`542`	`543`	`node.query(`