Faster test

ianton-ru · ianton-ru · commit fd36f73833fb · 2025-06-24T13:49:19.000+02:00
diff --git a/tests/integration/test_s3_cache_locality/test.py b/tests/integration/test_s3_cache_locality/test.py
@@ -110,8 +110,8 @@ def check_s3_gets(cluster, node, expected_result, cluster_first, cluster_second,
     )
     assert result_second == expected_result
 
-    for host in list(cluster.instances.values()):
-        host.query("SYSTEM FLUSH LOGS")
+    node.query(f"SYSTEM FLUSH LOGS ON CLUSTER {cluster_first}")
+    node.query(f"SYSTEM FLUSH LOGS ON CLUSTER {cluster_second}")
 
     s3_get_first = node.query(
         f"""

Original file line number	Diff line number	Diff line change
`@@ -110,8 +110,8 @@ def check_s3_gets(cluster, node, expected_result, cluster_first, cluster_second,`
`110`	`110`	`)`
`111`	`111`	`assert result_second == expected_result`
`112`	`112`
`113`		`- for host in list(cluster.instances.values()):`
`114`		`- host.query("SYSTEM FLUSH LOGS")`
	`113`	`+ node.query(f"SYSTEM FLUSH LOGS ON CLUSTER {cluster_first}")`
	`114`	`+ node.query(f"SYSTEM FLUSH LOGS ON CLUSTER {cluster_second}")`
`115`	`115`
`116`	`116`	`s3_get_first = node.query(`
`117`	`117`	`f"""`