From 4608aa06ed799eb4d6a2067fdbdfb0cefa1061d3 Mon Sep 17 00:00:00 2001 From: Florin Barbu Date: Fri, 19 Jan 2024 11:33:45 +0200 Subject: [PATCH] small fix --- tests/filter/test_get_messages.py | 1 + tests/filter/test_multiple_nodes.py | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/tests/filter/test_get_messages.py b/tests/filter/test_get_messages.py index e4b41825..f5f7a36c 100644 --- a/tests/filter/test_get_messages.py +++ b/tests/filter/test_get_messages.py @@ -117,6 +117,7 @@ class TestFilterGetMessages(StepsFilter): for index in range(num_messages): message = self.create_message(payload=to_base64(f"M_{index}")) self.node1.send_relay_message(message, self.test_pubsub_topic) + delay(0.01) delay(1) filter_messages = self.get_filter_messages(content_topic=self.test_content_topic, pubsub_topic=self.test_pubsub_topic, node=self.node2) assert len(filter_messages) == num_messages diff --git a/tests/filter/test_multiple_nodes.py b/tests/filter/test_multiple_nodes.py index 8e6acde4..f35e81bd 100644 --- a/tests/filter/test_multiple_nodes.py +++ b/tests/filter/test_multiple_nodes.py @@ -48,8 +48,8 @@ class TestFilterMultipleNodes(StepsFilter): self.check_published_message_reaches_filter_peer(peer_list=self.optional_nodes) def test_ping_only_some_nodes_have_subscriptions(self): - self.setup_optional_filter_nodes() self.wait_for_subscriptions_on_main_nodes([self.test_content_topic]) + self.setup_optional_filter_nodes() self.ping_filter_subscriptions("1", node=self.node2) for node in self.optional_nodes: self.ping_without_filter_subscription(node=node)