yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

test: attempt to reduce flakiness

This commit is contained in:
Thales Macedo Garitezi 2023-01-02 13:57:44 -03:00
parent 32922a6830
commit 5bd9f110d6
1 changed files with 16 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
lib-ee/emqx_ee_bridge/test/emqx_ee_bridge_redis_SUITE.erl
View File

@ -220,16 +220,24 @@ t_check_replay(Config) ->
begin begin
?wait_async_action( ?wait_async_action(
with_down_failure(Config, ProxyName, fun() -> with_down_failure(Config, ProxyName, fun() ->
ct:sleep(100), {_, {ok, _}} =
lists:foreach( ?wait_async_action(
fun(_) -> lists:foreach(
_ = publish_message(Topic, <<"test_payload">>) fun(_) ->
end, _ = publish_message(Topic, <<"test_payload">>)
lists:seq(1, ?BATCH_SIZE) end,
) lists:seq(1, ?BATCH_SIZE)
),
#{
?snk_kind := redis_ee_connector_send_done,
batch := true,
result := {error, _}
},
10_000
)
end), end),
#{?snk_kind := redis_ee_connector_send_done, batch := true, result := {ok, _}}, #{?snk_kind := redis_ee_connector_send_done, batch := true, result := {ok, _}},
10000 10_000
) )
end, end,
fun(Trace) -> fun(Trace) ->