From fa508a95c1309c85d6f1057ceceeb5e2d36ac07e Mon Sep 17 00:00:00 2001 From: Thales Macedo Garitezi Date: Mon, 29 May 2023 18:09:35 -0300 Subject: [PATCH] test(telemetry): fix flaky test ``` %%% emqx_telemetry_SUITE ==> Failure/Error: ?assertEqual(0, get_value ( num_clients , TelemetryData1 )) expected: 0 got: 1 line: 454 ``` --- apps/emqx_telemetry/test/emqx_telemetry_SUITE.erl | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/apps/emqx_telemetry/test/emqx_telemetry_SUITE.erl b/apps/emqx_telemetry/test/emqx_telemetry_SUITE.erl index 65604c4e5..3ef2142e8 100644 --- a/apps/emqx_telemetry/test/emqx_telemetry_SUITE.erl +++ b/apps/emqx_telemetry/test/emqx_telemetry_SUITE.erl @@ -430,25 +430,25 @@ t_num_clients(_Config) -> {port, 1883}, {clean_start, false} ]), - {{ok, _}, _} = ?wait_async_action( + {{ok, _}, {ok, _}} = ?wait_async_action( {ok, _} = emqtt:connect(Client), #{ ?snk_kind := emqx_stats_setstat, count_stat := 'live_connections.count', value := 1 }, - 2000 + 5_000 ), {ok, TelemetryData0} = emqx_telemetry:get_telemetry(), ?assertEqual(1, get_value(num_clients, TelemetryData0)), - {ok, _} = ?wait_async_action( + {ok, {ok, _}} = ?wait_async_action( ok = emqtt:disconnect(Client), #{ ?snk_kind := emqx_stats_setstat, count_stat := 'live_connections.count', value := 0 }, - 2000 + 5_000 ), {ok, TelemetryData1} = emqx_telemetry:get_telemetry(), ?assertEqual(0, get_value(num_clients, TelemetryData1)),