Ensure all nodes are up & discovered in upgrade bwc tests

crate · Jan 25, 2024 · ac20b25 · ac20b25
1 parent 4cd0259
commit ac20b25
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/tests/bwc/test_upgrade.py b/tests/bwc/test_upgrade.py
@@ -255,6 +255,7 @@ def assert_data_persistence(self,
         cluster = self._new_cluster(version, nodes, data_paths=paths, settings=self.CLUSTER_SETTINGS, env=env)
         cluster.start()
         with connect(cluster.node().http_url, error_trace=True) as conn:
+            assert_busy(lambda: self.assert_nodes(conn, nodes))
             cursor = conn.cursor()
             wait_for_active_shards(cursor, 0)
             cursor.execute('ALTER TABLE doc.t1 SET ("refresh_interval" = 4000)')