File tree Expand file tree Collapse file tree 1 file changed +5
-2
lines changed Expand file tree Collapse file tree 1 file changed +5
-2
lines changed Original file line number Diff line number Diff line change 3434-include_lib (" proper/include/proper.hrl" ).
3535-include_lib (" eunit/include/eunit.hrl" ).
3636-include_lib (" amqp_client/include/amqp_client.hrl" ).
37+ -include_lib (" rabbitmq_ct_helpers/include/rabbit_assert.hrl" ).
3738
3839-compile (export_all ).
3940
@@ -378,8 +379,10 @@ nodes_policy_should_pick_master_from_its_params(Config) ->
378379 [all ])),
379380 % % --> Master: A
380381 % % Slaves: [B, C] or [C, B]
381- Info = find_queue (? QNAME , A ),
382- SSPids = proplists :get_value (synchronised_slave_pids , Info ),
382+ SSPids = ? awaitMatch (SSPids when is_list (SSPids ),
383+ proplists :get_value (synchronized_slave_pids ,
384+ find_queue (? QNAME , A )),
385+ 5000 ),
383386
384387 % % Choose slave that isn't the first sync slave. Cover a bug that always
385388 % % chose the first, even if it was not part of the policy
You can’t perform that action at this time.
0 commit comments