diff options
| author | Karl Nilsson <kjnilsson@gmail.com> | 2022-08-11 15:46:35 +0100 |
|---|---|---|
| committer | Karl Nilsson <kjnilsson@gmail.com> | 2022-08-11 15:46:35 +0100 |
| commit | 8b029d4ad06428b1f12b701b6b98379b397900f7 (patch) | |
| tree | 5a1d2ea03a70cae118664dfc4fb9510e63a03a5a | |
| parent | 784d33549e318056e1bce3b2c319c002b56e4d83 (diff) | |
| download | rabbitmq-server-git-amqp10-client-system-flake.tar.gz | |
rabbit_stream_queue flake improvementamqp10-client-system-flake
By waiting for the first remove_replica command to complete we
may reduce the likelyhood of this test flaking.
| -rw-r--r-- | deps/rabbit/test/rabbit_stream_queue_SUITE.erl | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/deps/rabbit/test/rabbit_stream_queue_SUITE.erl b/deps/rabbit/test/rabbit_stream_queue_SUITE.erl index 7ba833d481..e76a6c2aef 100644 --- a/deps/rabbit/test/rabbit_stream_queue_SUITE.erl +++ b/deps/rabbit/test/rabbit_stream_queue_SUITE.erl @@ -543,6 +543,8 @@ delete_last_replica(Config) -> ?assertEqual(ok, rpc:call(Server0, rabbit_stream_queue, delete_replica, [<<"/">>, Q, Server1])), + + check_leader_and_replicas(Config, [Server0, Server2], members), ?assertEqual(ok, rpc:call(Server0, rabbit_stream_queue, delete_replica, [<<"/">>, Q, Server2])), |