diff --git a/src/steps/light_push.py b/src/steps/light_push.py index 9761c2db3..3980513cf 100644 --- a/src/steps/light_push.py +++ b/src/steps/light_push.py @@ -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) diff --git a/tests/conftest.py b/tests/conftest.py index 48cd71446..e76ee9ab3 100644 --- a/tests/conftest.py +++ b/tests/conftest.py @@ -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 "