test(ds): fix flaky test

emqx · Mar 25, 2024 · b0d291a · b0d291a
1 parent 30c2b81
commit b0d291a
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/apps/emqx_durable_storage/test/emqx_ds_storage_bitfield_lts_SUITE.erl b/apps/emqx_durable_storage/test/emqx_ds_storage_bitfield_lts_SUITE.erl
@@ -278,6 +278,7 @@ t_atomic_store_batch(_Config) ->
 t_non_atomic_store_batch(_Config) ->
     DB = ?FUNCTION_NAME,
     ?check_trace(
+        #{timetrap => 10_000},
         begin
             application:set_env(emqx_durable_storage, egress_batch_size, 1),
             Msgs = [
@@ -293,6 +294,10 @@ t_non_atomic_store_batch(_Config) ->
                     sync => true
                 })
             ),
+            snabbkaffe:block_until(
+                ?match_n_events(3, #{?snk_kind := emqx_ds_replication_layer_egress_flush}),
+                infinity
+            ),
 
             ok
         end,