diff --git a/tests/functional/pv/pv_services/test_verify_rwo_using_dc_pod.py b/tests/functional/pv/pv_services/test_verify_rwo_using_dc_pod.py index d8923aaa596..2b3d5bcb12a 100644 --- a/tests/functional/pv/pv_services/test_verify_rwo_using_dc_pod.py +++ b/tests/functional/pv/pv_services/test_verify_rwo_using_dc_pod.py @@ -10,6 +10,7 @@ from ocs_ci.ocs.resources import pod from ocs_ci.ocs.ocp import OCP from ocs_ci.helpers.helpers import wait_for_resource_state, create_pod +from ocs_ci.framework import config from ocs_ci.utility.utils import TimeoutSampler @@ -82,9 +83,14 @@ def wait_for_pods_and_verify(self): """ Wait for the pods to be created and verify only one pod is running """ + timeout_value = 360 + + if config.ENV_DATA.get("worker_replicas") == 0: + timeout_value = 600 + # Wait for pods for pods in TimeoutSampler( - 360, + timeout_value, 2, func=pod.get_all_pods, namespace=self.namespace, @@ -98,7 +104,7 @@ def wait_for_pods_and_verify(self): # Wait for one pod to be in Running state curr_pod = next(pods_iter) - sampler = TimeoutSampler(360, 2, curr_pod.get) + sampler = TimeoutSampler(timeout_value, 2, curr_pod.get) for pod_info in sampler: if pod_info["status"]["phase"] == constants.STATUS_RUNNING: self.running_pod = curr_pod