diff options
| -rw-r--r-- | tests/functional/common/provisioning/test_dynamic_provisioning_block_p0_cases.py | 6 | ||||
| -rw-r--r-- | tests/functional/common/provisioning/test_dynamic_provisioning_p0_cases.py | 6 |
2 files changed, 12 insertions, 0 deletions
diff --git a/tests/functional/common/provisioning/test_dynamic_provisioning_block_p0_cases.py b/tests/functional/common/provisioning/test_dynamic_provisioning_block_p0_cases.py index f756a759..aa58f060 100644 --- a/tests/functional/common/provisioning/test_dynamic_provisioning_block_p0_cases.py +++ b/tests/functional/common/provisioning/test_dynamic_provisioning_block_p0_cases.py @@ -1,3 +1,5 @@ +import time + from cnslibs.common.dynamic_provisioning import ( create_mongodb_pod, create_secret_file, @@ -249,6 +251,10 @@ class TestDynamicProvisioningBlockP0(CnsGlusterBlockBaseClass): self.assertEqual(ret, 0, "failed to execute command %s on %s" % ( heketi_up_cmd, self.ocp_master_node[0])) + # Wait small amount of time before newly scheduled Heketi POD appears + time.sleep(2) + + # Wait for Heketi POD be up and running ret, out, err = g.run(self.ocp_master_node[0], get_heketi_podname_cmd) ret = verify_pod_status_running( self.ocp_master_node[0], out.strip(), wait_step=5, timeout=120) diff --git a/tests/functional/common/provisioning/test_dynamic_provisioning_p0_cases.py b/tests/functional/common/provisioning/test_dynamic_provisioning_p0_cases.py index c08bbf9b..9bd85db8 100644 --- a/tests/functional/common/provisioning/test_dynamic_provisioning_p0_cases.py +++ b/tests/functional/common/provisioning/test_dynamic_provisioning_p0_cases.py @@ -1,3 +1,5 @@ +import time + from cnslibs.common.dynamic_provisioning import ( create_mongodb_pod, create_secret_file, @@ -220,6 +222,10 @@ class TestDynamicProvisioningP0(CnsBaseClass): self.assertEqual(ret, 0, "failed to execute command %s on %s" % ( heketi_up_cmd, self.ocp_master_node[0])) + # Wait small amount of time before newly scheduled Heketi POD appears + time.sleep(2) + + # Wait for Heketi POD be up and running ret, out, err = g.run(self.ocp_master_node[0], get_heketi_podname_cmd) ret = verify_pod_status_running( self.ocp_master_node[0], out.strip(), wait_step=5, timeout=120) |