fix test

bharatnc · bharatnc · commit cc63c4f1d4e3 · 2025-04-06T22:26:05.000-07:00
diff --git a/tests/integration/test_storage_s3_queue/test_4.py b/tests/integration/test_storage_s3_queue/test_4.py
@@ -624,6 +624,10 @@ def get_count():
         database_name=db_name,
     )
 
+    # ensure that the table is created on node2 before we query the registry as there might be a race between the time
+    # we actually create the table on node2 and when we query the registry.
+    node2.query(f"SYSTEM SYNC DATABASE REPLICA {db_name}")
+
     registry, stat = zk.get(f"{keeper_path}/registry/")
 
     uuid2 = node1.query(

Original file line number	Diff line number	Diff line change
`@@ -624,6 +624,10 @@ def get_count():`
`624`	`624`	`database_name=db_name,`
`625`	`625`	`)`
`626`	`626`
	`627`	`+ # ensure that the table is created on node2 before we query the registry as there might be a race between the time`
	`628`	`+ # we actually create the table on node2 and when we query the registry.`
	`629`	`+ node2.query(f"SYSTEM SYNC DATABASE REPLICA {db_name}")`
	`630`	`+`
`627`	`631`	`registry, stat = zk.get(f"{keeper_path}/registry/")`
`628`	`632`
`629`	`633`	`uuid2 = node1.query(`