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-07 16:33:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add more wait to pass CI

Browse Source
This commit is contained in:
aya 2024-11-07 01:35:39 +02:00
parent 254c160f42
commit a002fa5873
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
tests/e2e/test_e2e.py
View File

@ -242,13 +242,14 @@ class TestE2E(StepsFilter, StepsStore, StepsRelay, StepsLightPush):
node.set_relay_subscriptions([self.test_pubsub_topic]) node.set_relay_subscriptions([self.test_pubsub_topic])
logger.debug(f"Node5 makes filter request pubsubtopic {self.test_pubsub_topic} and content topic {self.test_content_topic}") logger.debug(f"Node5 makes filter request pubsubtopic {self.test_pubsub_topic} and content topic {self.test_content_topic}")
self.node5.set_filter_subscriptions({"requestId": "1", "contentFilters": [self.test_content_topic], "pubsubTopic": self.test_pubsub_topic}) self.node5.set_filter_subscriptions({"requestId": "1", "contentFilters": [self.test_content_topic], "pubsubTopic": self.test_pubsub_topic})
self.wait_for_autoconnection(node_list, hard_wait=30) node_list.append(self.node5)
self.wait_for_autoconnection(node_list, hard_wait=60)
logger.debug(f" {total_senders} Nodes publish {messages_num} message") logger.debug(f" {total_senders} Nodes publish {messages_num} message")
for node in node_list[:-1]: for node in node_list[:-2]:
for i in range(messages_num // total_senders): for i in range(messages_num // total_senders):
self.publish_message(sender=node, pubsub_topic=self.test_pubsub_topic, message=self.create_message()) self.publish_message(sender=node, pubsub_topic=self.test_pubsub_topic, message=self.create_message())
delay(0.2) delay(2)
logger.debug(f"Node5 requests messages of subscribed filter topic {self.test_pubsub_topic}") logger.debug(f"Node5 requests messages of subscribed filter topic {self.test_pubsub_topic}")
messages_response = self.get_filter_messages(self.test_content_topic, pubsub_topic=self.test_pubsub_topic, node=self.node5) messages_response = self.get_filter_messages(self.test_content_topic, pubsub_topic=self.test_pubsub_topic, node=self.node5)
@ -269,7 +270,6 @@ class TestE2E(StepsFilter, StepsStore, StepsRelay, StepsLightPush):
node_list_relay = [self.node1, self.node2] node_list_relay = [self.node1, self.node2]
for node in node_list_relay: for node in node_list_relay:
node.set_relay_subscriptions([self.test_pubsub_topic]) node.set_relay_subscriptions([self.test_pubsub_topic])
self.wait_for_autoconnection(node_list_relay, hard_wait=30)
node_list.append(self.node2) node_list.append(self.node2)
logger.debug(f"{max_subscribed_nodes} Node start and making filter requests to node2") logger.debug(f"{max_subscribed_nodes} Node start and making filter requests to node2")
@ -287,7 +287,7 @@ class TestE2E(StepsFilter, StepsStore, StepsRelay, StepsLightPush):
node_list[i + 1].set_filter_subscriptions( node_list[i + 1].set_filter_subscriptions(
{"requestId": "1", "contentFilters": [self.test_content_topic], "pubsubTopic": self.test_pubsub_topic} {"requestId": "1", "contentFilters": [self.test_content_topic], "pubsubTopic": self.test_pubsub_topic}
) )
delay(30) self.wait_for_autoconnection(node_list_relay, hard_wait=100)
logger.debug("Node1 publish message") logger.debug("Node1 publish message")
self.publish_message(sender=self.node1, pubsub_topic=self.test_pubsub_topic, message=self.create_message()) self.publish_message(sender=self.node1, pubsub_topic=self.test_pubsub_topic, message=self.create_message())