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 index 4dbc1a11d..3357406ff 100644 --- 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"]}]),