logos-messaging/logos-messaging-interop-tests
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-messaging-interop-tests.git synced 2026-01-11 10:23:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

small fix

Browse Source
This commit is contained in:
Florin Barbu 2024-01-19 11:33:45 +02:00
parent abfe6b2f65
commit 4608aa06ed
No known key found for this signature in database
GPG Key ID: 593D6DBC6D9E5095
2 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
tests/filter/test_get_messages.py
View File

@ -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

2
tests/filter/test_multiple_nodes.py
View File

@ -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)