Skip to content

Commit ada5e28

Browse files
committed
Remove test flake
Prior to this commit tests * leader_transfer_quorum_queue_credit_single * leader_transfer_quorum_queue_credit_batches flaked in CI during 4.1 (main) and 4.0 mixed version testing. The follwing error occurred on node 0: ``` [error] <0.1950.0> Timed out waiting for credit reply from quorum queue 'leader_transfer_quorum_queue_credit_batches' in vhost '/'. Hint: Enable feature flag rabbitmq_4.0.0 [warning] <0.1950.0> Closing session for connection <0.1945.0>: {'v1_0.error', [warning] <0.1950.0> {symbol,<<"amqp:internal-error">>}, [warning] <0.1950.0> {utf8, [warning] <0.1950.0> <<"Timed out waiting for credit reply from quorum queue 'leader_transfer_quorum_queue_credit_batches' in vhost '/'. Hint: Enable feature flag rabbitmq_4.0.0">>}, [warning] <0.1950.0> undefined} ``` Therefore we enable this feature flag for both tests.
1 parent 2c0cdee commit ada5e28

File tree

1 file changed

+15
-28
lines changed

1 file changed

+15
-28
lines changed

deps/rabbit/test/amqp_client_SUITE.erl

Lines changed: 15 additions & 28 deletions
Original file line numberDiff line numberDiff line change
@@ -303,12 +303,15 @@ init_per_testcase(T, Config)
303303
when T =:= detach_requeues_one_session_quorum_queue orelse
304304
T =:= single_active_consumer_quorum_queue orelse
305305
T =:= detach_requeues_two_connections_quorum_queue ->
306-
case rabbit_ct_broker_helpers:enable_feature_flag(Config, 'rabbitmq_4.0.0') of
307-
ok ->
308-
rabbit_ct_helpers:testcase_started(Config, T);
309-
{skip, _} ->
310-
{skip, "Feature flag rabbitmq_4.0.0 enables the consumer removal API"}
311-
end;
306+
%% Feature flag rabbitmq_4.0.0 enables the consumer removal API.
307+
ok = rabbit_ct_broker_helpers:enable_feature_flag(Config, 'rabbitmq_4.0.0'),
308+
rabbit_ct_helpers:testcase_started(Config, T);
309+
init_per_testcase(T, Config)
310+
when T =:= leader_transfer_quorum_queue_credit_single orelse
311+
T =:= leader_transfer_quorum_queue_credit_batches ->
312+
%% These test cases flake with feature flag 'rabbitmq_4.0.0' disabled.
313+
ok = rabbit_ct_broker_helpers:enable_feature_flag(Config, 'rabbitmq_4.0.0'),
314+
rabbit_ct_helpers:testcase_started(Config, T);
312315
init_per_testcase(T = immutable_bare_message, Config) ->
313316
case rpc(Config, rabbit_feature_flags, is_enabled, ['rabbitmq_4.0.0']) of
314317
true ->
@@ -333,19 +336,6 @@ init_per_testcase(T = dead_letter_reject, Config) ->
333336
{skip, "This test is known to fail with feature flag message_containers_deaths_v2 disabled "
334337
"due bug https://github.com/rabbitmq/rabbitmq-server/issues/11159"}
335338
end;
336-
init_per_testcase(T, Config)
337-
when T =:= leader_transfer_quorum_queue_credit_single orelse
338-
T =:= leader_transfer_quorum_queue_credit_batches orelse
339-
T =:= leader_transfer_stream_credit_single orelse
340-
T =:= leader_transfer_stream_credit_batches orelse
341-
T =:= leader_transfer_quorum_queue_send orelse
342-
T =:= leader_transfer_stream_send ->
343-
case rpc(Config, rabbit_feature_flags, is_supported, ['rabbitmq_4.0.0']) of
344-
true ->
345-
rabbit_ct_helpers:testcase_started(Config, T);
346-
false ->
347-
{skip, "This test requires the AMQP management extension of RabbitMQ 4.0"}
348-
end;
349339
init_per_testcase(T, Config)
350340
when T =:= classic_queue_on_new_node orelse
351341
T =:= quorum_queue_on_new_node ->
@@ -3543,14 +3533,11 @@ async_notify_settled_stream(Config) ->
35433533
async_notify(settled, <<"stream">>, Config).
35443534

35453535
async_notify_unsettled_classic_queue(Config) ->
3546-
case rabbit_ct_broker_helpers:enable_feature_flag(Config, 'rabbitmq_4.0.0') of
3547-
ok ->
3548-
async_notify(unsettled, <<"classic">>, Config);
3549-
{skip, _} ->
3550-
{skip, "Skipping as this test will flake. Link flow control in classic "
3551-
"queues with credit API v1 is known to be broken: "
3552-
"https://github.com/rabbitmq/rabbitmq-server/issues/2597"}
3553-
end.
3536+
%% This test flakes with feature flag 'rabbitmq_4.0.0' disabled.
3537+
%% Link flow control in classic queues with credit API v1 is known to be broken:
3538+
%% https://github.com/rabbitmq/rabbitmq-server/issues/2597
3539+
ok = rabbit_ct_broker_helpers:enable_feature_flag(Config, 'rabbitmq_4.0.0'),
3540+
async_notify(unsettled, <<"classic">>, Config).
35543541

35553542
async_notify_unsettled_quorum_queue(Config) ->
35563543
async_notify(unsettled, <<"quorum">>, Config).
@@ -3852,7 +3839,6 @@ leader_transfer_credit(QName, QType, Credit, Config) ->
38523839
ok = end_session_sync(Session1),
38533840
ok = close_connection_sync(Connection1),
38543841

3855-
%% Consume from a follower.
38563842
OpnConf = connection_config(0, Config),
38573843
{ok, Connection0} = amqp10_client:open_connection(OpnConf),
38583844
{ok, Session0} = amqp10_client:begin_session_sync(Connection0),
@@ -3866,6 +3852,7 @@ leader_transfer_credit(QName, QType, Credit, Config) ->
38663852
ok = wait_for_accepts(NumMsgs),
38673853
ok = detach_link_sync(Sender),
38683854

3855+
%% Consume from a follower.
38693856
ok = wait_for_local_member(QType, QName, Config),
38703857
Filter = consume_from_first(QType),
38713858
{ok, Receiver} = amqp10_client:attach_receiver_link(

0 commit comments

Comments
 (0)