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

fix: different propagation delay for fleet test

Browse Source
This commit is contained in:
Roman 2026-05-04 16:36:41 +08:00
parent ef7c917acf
commit 8919de9360
No known key found for this signature in database
GPG Key ID: 583BDF43C238B83E
2 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/steps/light_push.py
View File

@ -22,6 +22,7 @@ class StepsLightPush(StepsCommon):
test_content_topic = "/myapp/1/latest/proto"
test_pubsub_topic = VALID_PUBSUB_TOPICS[0]
test_payload = "Light push works!!"
default_message_propagation_delay = 0.1
@pytest.fixture(scope="function", autouse=True)
def light_push_setup(self):
@ -109,7 +110,7 @@ class StepsLightPush(StepsCommon):
@allure.step
def check_light_pushed_message_reaches_receiving_peer(
self, pubsub_topic=None, message=None, message_propagation_delay=0.1, sender=None, peer_list=None
self, pubsub_topic=None, message=None, message_propagation_delay=None, sender=None, peer_list=None
):
if pubsub_topic is None:
pubsub_topic = self.test_pubsub_topic
@ -117,6 +118,8 @@ class StepsLightPush(StepsCommon):
sender = self.light_push_node1
if not peer_list:
peer_list = self.main_receiving_nodes + self.optional_nodes
if message_propagation_delay is None:
message_propagation_delay = self.default_message_propagation_delay
payload = self.create_payload(pubsub_topic, message)
logger.debug("Lightpushing message")
sender.send_light_push_message(payload)

1
tests/conftest.py
View File

@ -194,6 +194,7 @@ def configure_fleet_cluster(request, pubsub_cfg):
return node
StepsLightPush.setup_lightpush_node = _fleet_setup_lightpush_node
StepsLightPush.default_message_propagation_delay = 0.5
logger.info(
"Fleet cluster config active – pubsub topics overridden to cluster-id=%s "