Test flakes may05 2026 (#16305)

* quorum_queue_SUITE: await condition

Sometimes we can get `{error,4, {error, non_voters_found}}`
if we don't wait

* mqtt_shared_SUITE: await

basic.get could have happened before the message was ready

(cherry picked from commit e56c164)

Author: mkuratczyk

deps/rabbit/test/quorum_queue_SUITE.erl

@@ -2159,8 +2159,16 @@ grow_queue(Config) ->
 
     %% grow queues to quorum cluster size > '5' (limit = 5).
     TargetClusterSize_10 = 10,
-    Result5 = rpc:call(Server0, rabbit_quorum_queue, grow, [TargetClusterSize_10, <<"/">>, <<".*">>, all]),
-    ?assert(lists:all(fun({_, {R, _}}) -> R =:= ok end, Result5)),
+    rabbit_ct_helpers:await_condition(
+        fun() ->
+            rpc:call(Server0, rabbit_quorum_queue, grow,
+                     [TargetClusterSize_10, <<"/">>, <<".*">>, all]),
+            lists:all(
+                fun(Q) ->
+                    {ok, Q0} = rpc:call(Server0, rabbit_amqqueue, lookup, [Q, <<"/">>]),
+                    length(rabbit_queue_type:get_nodes(Q0)) =:= TargetClusterSize_5
+                end, QQs)
+        end, 30_000),
     assert_grown_queues(QQs, Server0, TargetClusterSize_5, MsgCount),
 
     %% shrink all queues again down to 1 member

deps/rabbitmq_mqtt/test/mqtt_shared_SUITE.erl

@@ -1698,10 +1698,10 @@ trace(Config) ->
                    <<"routed_queues">> := [<<"mqtt-subscription-trace_subscriberqos0">>]},
                  rabbit_misc:amqp_table(PublishHeaders)),
 
-    {#'basic.get_ok'{routing_key = <<"deliver.mqtt-subscription-trace_subscriberqos0">>},
-     #amqp_msg{props = #'P_basic'{headers = DeliverHeaders},
-               payload = Payload}} =
-    amqp_channel:call(Ch, #'basic.get'{queue = TraceQ}),
+    {_, #amqp_msg{props = #'P_basic'{headers = DeliverHeaders}, payload = Payload}} =
+        ?awaitMatch({#'basic.get_ok'{routing_key = <<"deliver.mqtt-subscription-trace_subscriberqos0">>}, _},
+                    amqp_channel:call(Ch, #'basic.get'{queue = TraceQ}),
+                    5_000),
     ?assertMatch(#{<<"exchange_name">> := <<"amq.topic">>,
                    <<"routing_keys">> := [Topic],
                    <<"connection">> := <<"127.0.0.1:", _/binary>>,