We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 92b03f0 commit dac342bCopy full SHA for dac342b
tests/integration/test_cluster_discovery/test.py
@@ -125,6 +125,13 @@ def test_cluster_discovery_startup_and_stop(start_cluster):
125
126
127
def test_cluster_discovery_macros(start_cluster):
128
+ # wait for all nodes to be started
129
+ check_nodes_count = functools.partial(
130
+ check_on_cluster, what="count()", msg="Wrong nodes count in cluster"
131
+ )
132
+ total_nodes = len(nodes) - 1
133
+ check_nodes_count([nodes["node_observer"]], total_nodes)
134
+
135
# check macros
136
res = nodes["node_observer"].query(
137
"SELECT sum(number) FROM clusterAllReplicas('{autocluster}', system.numbers) WHERE number=1"
0 commit comments