From e1de18ef102cb5da61d429f48a66dbb03ab11521 Mon Sep 17 00:00:00 2001 From: Andrew Mayorov Date: Wed, 26 Jun 2024 20:42:59 +0200 Subject: [PATCH] test(dsrepl): await stable state before running testcase --- apps/emqx_ds_builtin_raft/test/emqx_ds_replication_SUITE.erl | 1 + 1 file changed, 1 insertion(+) diff --git a/apps/emqx_ds_builtin_raft/test/emqx_ds_replication_SUITE.erl b/apps/emqx_ds_builtin_raft/test/emqx_ds_replication_SUITE.erl index fe0a30489..d3eed99df 100644 --- a/apps/emqx_ds_builtin_raft/test/emqx_ds_replication_SUITE.erl +++ b/apps/emqx_ds_builtin_raft/test/emqx_ds_replication_SUITE.erl @@ -140,6 +140,7 @@ t_replication_transfers_snapshots(Config) -> %% Stop the DB on the "offline" node. ok = emqx_cth_cluster:stop_node(NodeOffline), + _ = ?block_until(#{?snk_kind := ds_ra_state_enter, state := leader}, 500, 0), %% Fill the storage with messages and few additional generations. emqx_ds_test_helpers:apply_stream(?DB, Nodes -- [NodeOffline], Stream),