diff --git a/lib-ee/emqx_ee_bridge/test/emqx_ee_bridge_gcp_pubsub_SUITE.erl b/lib-ee/emqx_ee_bridge/test/emqx_ee_bridge_gcp_pubsub_SUITE.erl
index f68c1391f..70125596c 100644
--- a/lib-ee/emqx_ee_bridge/test/emqx_ee_bridge_gcp_pubsub_SUITE.erl
+++ b/lib-ee/emqx_ee_bridge/test/emqx_ee_bridge_gcp_pubsub_SUITE.erl
@@ -1136,6 +1136,8 @@ do_econnrefused_or_timeout_test(Config, Error) ->
             wait_telemetry_event(TelemetryTable, success, ResourceId, #{
                 timeout => 10_000, n_events => 2
             }),
+            wait_until_gauge_is(inflight, 0, _Timeout = 400),
+            wait_until_gauge_is(queuing, 0, _Timeout = 400),
             assert_metrics(
                 #{
                     batching => 0,