Skip to content

Commit ab65dc9

Browse files
authored
Merge pull request #10448 from rabbitmq/fix-flake-in-rabbit_stream_queue_SUITE
rabbit_stream_queue_SUITE: Wait for `ra_leaderboard` to return the leader
2 parents 8a8230c + 2a0563b commit ab65dc9

File tree

1 file changed

+7
-0
lines changed

1 file changed

+7
-0
lines changed

deps/rabbit/test/rabbit_stream_queue_SUITE.erl

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1381,6 +1381,13 @@ recover_coordinator(Config, Node) ->
13811381

13821382
get_stream_coordinator_leader(Config) ->
13831383
Node = hd(rabbit_ct_broker_helpers:get_node_configs(Config, nodename)),
1384+
rabbit_ct_helpers:await_condition(
1385+
fun() ->
1386+
Ret = rabbit_ct_broker_helpers:rpc(
1387+
Config, Node, ra_leaderboard, lookup_leader,
1388+
[rabbit_stream_coordinator]),
1389+
is_tuple(Ret)
1390+
end),
13841391
rabbit_ct_broker_helpers:rpc(Config, Node, ra_leaderboard,
13851392
lookup_leader, [rabbit_stream_coordinator]).
13861393

0 commit comments

Comments
 (0)