From 6550cd1752571b4955f96875d60b0cc429e5a4f1 Mon Sep 17 00:00:00 2001 From: Michael Klishin Date: Mon, 21 Jun 2021 14:39:05 +0800 Subject: [PATCH] Reduce flakiness in rabbitmq_queues_cli_integration_SUITE In case removed node hosts a leader, it takes a moment for the QQ to elect a new one and begin accepting cluster membership change operations again. (cherry picked from commit a9d8816c6a6e74c34ee3b1c2bd4ef5383924b13b) --- deps/rabbit/test/rabbitmq_queues_cli_integration_SUITE.erl | 3 +++ 1 file changed, 3 insertions(+) diff --git a/deps/rabbit/test/rabbitmq_queues_cli_integration_SUITE.erl b/deps/rabbit/test/rabbitmq_queues_cli_integration_SUITE.erl index 8e7243db23..0536f0480e 100644 --- a/deps/rabbit/test/rabbitmq_queues_cli_integration_SUITE.erl +++ b/deps/rabbit/test/rabbitmq_queues_cli_integration_SUITE.erl @@ -77,10 +77,12 @@ shrink(Config) -> publish_confirm(Ch, QName), {ok, Out1} = rabbitmq_queues(Config, 0, ["shrink", Nodename2]), ?assertMatch(#{{"/", "shrink1"} := {2, ok}}, parse_result(Out1)), + timer:sleep(1500), Nodename1 = rabbit_ct_broker_helpers:get_node_config(Config, 1, nodename), publish_confirm(Ch, QName), {ok, Out2} = rabbitmq_queues(Config, 0, ["shrink", Nodename1]), ?assertMatch(#{{"/", "shrink1"} := {1, ok}}, parse_result(Out2)), + timer:sleep(1500), Nodename0 = rabbit_ct_broker_helpers:get_node_config(Config, 0, nodename), publish_confirm(Ch, QName), {ok, Out3} = rabbitmq_queues(Config, 0, ["shrink", Nodename0]), @@ -100,6 +102,7 @@ grow(Config) -> publish_confirm(Ch, QName), {ok, Out1} = rabbitmq_queues(Config, 0, ["grow", Nodename0, "all"]), ?assertMatch(#{{"/", "grow1"} := {2, ok}}, parse_result(Out1)), + timer:sleep(500), Nodename1 = rabbit_ct_broker_helpers:get_node_config(Config, 1, nodename), publish_confirm(Ch, QName), {ok, Out2} = rabbitmq_queues(Config, 0, ["grow", Nodename1, "all"]),