From c9ec5ac87b4c2487ebea3732942615a1d9df382f Mon Sep 17 00:00:00 2001 From: Thales Macedo Garitezi Date: Fri, 21 Jun 2024 14:07:56 -0300 Subject: [PATCH] test(gcp consumer): stabilize flaky test https://github.com/emqx/emqx/actions/runs/9614788348/job/26526973635?pr=13317#step:5:1463 ``` %%% emqx_bridge_gcp_pubsub_consumer_SUITE ==> t_connection_down_before_starting: FAILED %%% emqx_bridge_gcp_pubsub_consumer_SUITE ==> {{panic, #{msg => "Unexpected result", result => {run_stage_failed,error, {assertMatch, [{module,emqx_bridge_gcp_pubsub_consumer_SUITE}, {line,1451}, {expression,"health_check ( Config )"}, {pattern,"{ ok , connecting }"}, {value,{ok,disconnected}}]}, [{emqx_bridge_gcp_pubsub_consumer_SUITE, '-t_connection_down_before_starting/1-fun-11-',4, [{file, "/emqx/apps/emqx_bridge_gcp_pubsub/test/emqx_bridge_gcp_pubsub_consumer_SUITE.erl"}, {line,1451}]}, {emqx_bridge_gcp_pubsub_consumer_SUITE, t_connection_down_before_starting,1, [{file, "/emqx/apps/emqx_bridge_gcp_pubsub/test/emqx_bridge_gcp_pubsub_consumer_SUITE.erl"}, {line,1427}]}]}}}, [{emqx_bridge_gcp_pubsub_consumer_SUITE,t_connection_down_before_starting,1, [{file, "/emqx/apps/emqx_bridge_gcp_pubsub/test/emqx_bridge_gcp_pubsub_consumer_SUITE.erl"}, {line,1462}]}, {test_server,ts_tc,3,[{file,"test_server.erl"},{line,1793}]}, {test_server,run_test_case_eval1,6,[{file,"test_server.erl"},{line,1302}]}, {test_server,run_test_case_eval,9,[{file,"test_server.erl"},{line,1234}]}]} ``` --- .../test/emqx_bridge_gcp_pubsub_consumer_SUITE.erl | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/apps/emqx_bridge_gcp_pubsub/test/emqx_bridge_gcp_pubsub_consumer_SUITE.erl b/apps/emqx_bridge_gcp_pubsub/test/emqx_bridge_gcp_pubsub_consumer_SUITE.erl index c96eeeccf..9450d02f0 100644 --- a/apps/emqx_bridge_gcp_pubsub/test/emqx_bridge_gcp_pubsub_consumer_SUITE.erl +++ b/apps/emqx_bridge_gcp_pubsub/test/emqx_bridge_gcp_pubsub_consumer_SUITE.erl @@ -1448,7 +1448,10 @@ t_connection_down_before_starting(Config) -> ), {ok, _} = create_bridge(Config), {ok, _} = snabbkaffe:receive_events(SRef0), - ?assertMatch({ok, connecting}, health_check(Config)), + ?assertMatch( + {ok, Status} when Status =:= connecting orelse Status =:= disconnected, + health_check(Config) + ), emqx_common_test_helpers:heal_failure(down, ProxyName, ProxyHost, ProxyPort), ?retry(