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)