Sfoglia il codice sorgente

test: attempt to fix flaky kafka consumer test

It might need some time for the metrics to be set.
Thales Macedo Garitezi 2 anni fa
parent
commit
7e6f52e8fe

+ 5 - 1
lib-ee/emqx_ee_bridge/test/emqx_bridge_impl_kafka_consumer_SUITE.erl

@@ -1623,7 +1623,11 @@ t_bridge_rule_action_source(Config) ->
                 },
                 emqx_json:decode(RawPayload, [return_maps])
             ),
-            ?assertEqual(1, emqx_resource_metrics:received_get(ResourceId)),
+            ?retry(
+                _Interval = 200,
+                _NAttempts = 20,
+                ?assertEqual(1, emqx_resource_metrics:received_get(ResourceId))
+            ),
             ok
         end
     ),