From 024ffe29092dee3ee3841dc97574cad6a8578757 Mon Sep 17 00:00:00 2001 From: Thales Macedo Garitezi Date: Tue, 23 Jan 2024 09:47:03 -0300 Subject: [PATCH] test(ds): reduce flakiness --- .../test/emqx_persistent_messages_SUITE.erl | 17 +++++++++++++---- 1 file changed, 13 insertions(+), 4 deletions(-) diff --git a/apps/emqx/test/emqx_persistent_messages_SUITE.erl b/apps/emqx/test/emqx_persistent_messages_SUITE.erl index 73c88adc8..36c8848cf 100644 --- a/apps/emqx/test/emqx_persistent_messages_SUITE.erl +++ b/apps/emqx/test/emqx_persistent_messages_SUITE.erl @@ -438,10 +438,19 @@ t_message_gc(Config) -> TopicFilter = emqx_topic:words(<<"#">>), StartTime = 0, Msgs = consume(TopicFilter, StartTime), - %% only "1" and "2" should have been GC'ed - ?assertEqual( - sets:from_list([<<"3">>, <<"4">>], [{version, 2}]), - sets:from_list([emqx_message:payload(Msg) || Msg <- Msgs], [{version, 2}]) + %% "1" and "2" should have been GC'ed + PresentMessages = sets:from_list( + [emqx_message:payload(Msg) || Msg <- Msgs], + [{version, 2}] + ), + ?assert( + sets:is_empty( + sets:intersection( + PresentMessages, + sets:from_list([<<"1">>, <<"2">>], [{version, 2}]) + ) + ), + #{present_messages => PresentMessages} ), ok