summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorValerii Ponomarov <vponomar@redhat.com>2018-07-16 13:42:46 +0300
committerValerii Ponomarov <vponomar@redhat.com>2018-07-16 13:45:53 +0300
commitb7f6a80ceb1af26dec130facb64485ded0db18b2 (patch)
tree5d47c67f870d6df07dd53a28ba8d390bb719b467
parent436f6c8096c099b31ed083ca22d279e0bae88828 (diff)
Fix concurrency issue in heketi pod failure test cases
In those tests, we scale down amount of heketi pods to 0 and then scale it up back to amount of 1. And right after it, we perform request for list of Heketi PODs, not waiting for Heketi POD appearing in list. So, fix it by adding waiting for 2 sec which is enough time for Heketi POD to appear in the POD list. Change-Id: I5361d5c6eb98ac46b5f49a70edd0a88d550ab0b8
-rw-r--r--tests/functional/common/provisioning/test_dynamic_provisioning_block_p0_cases.py6
-rw-r--r--tests/functional/common/provisioning/test_dynamic_provisioning_p0_cases.py6
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)