From 5aa96a7c40d57573fb3fb08fc1b5ac267bd84d57 Mon Sep 17 00:00:00 2001 From: Eddy Babetto Date: Wed, 13 Mar 2024 18:10:08 +0100 Subject: [PATCH] Edit trigger engine test Edit trigger engine test with a workaround to assure 100% success rate for async tests Signed-off-by: Eddy Babetto --- .../test/amqp_consumer/amqp_consumer_tracker_test.exs | 2 ++ 1 file changed, 2 insertions(+) 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"]}]),