Edit trigger engine test

Edit trigger engine test with a workaround to assure 100% success rate for async tests Signed-off-by: Eddy Babetto <[email protected]>
astarte-platform · Mar 13, 2024 · 1e8a878 · 1e8a878
1 parent c17ee3a
commit 1e8a878
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/apps/astarte_trigger_engine/test/amqp_consumer/amqp_consumer_tracker_test.exs b/apps/astarte_trigger_engine/test/amqp_consumer/amqp_consumer_tracker_test.exs
@@ -83,6 +83,7 @@ defmodule Astarte.TriggerEngine.AMQPConsumer.AMQPConsumerTrackerTest do
 
     # make sure we update the consumer list without waiting for the update timeout
     AMQPConsumerTracker.handle_info(:update_consumers, [])
+    Process.sleep(3000)
 
     assert Enum.member?(
              Registry.select(Registry.AMQPConsumerRegistry, [{{:"$1", :_, :_}, [], [:"$1"]}]),
@@ -93,6 +94,7 @@ defmodule Astarte.TriggerEngine.AMQPConsumer.AMQPConsumerTrackerTest do
 
     # make sure we update the consumer list without waiting for the update timeout
     AMQPConsumerTracker.handle_info(:update_consumers, [])
+    Process.sleep(3000)
 
     assert not Enum.member?(
              Registry.select(Registry.AMQPConsumerRegistry, [{{:"$1", :_, :_}, [], [:"$1"]}]),