summaryrefslogtreecommitdiffstats
path: root/openshift-storage-libs/openshiftstoragelibs
diff options
context:
space:
mode:
Diffstat (limited to 'openshift-storage-libs/openshiftstoragelibs')
-rw-r--r--openshift-storage-libs/openshiftstoragelibs/openshift_ops.py20
1 files changed, 20 insertions, 0 deletions
diff --git a/openshift-storage-libs/openshiftstoragelibs/openshift_ops.py b/openshift-storage-libs/openshiftstoragelibs/openshift_ops.py
index b91b7fc1..0ed293d7 100644
--- a/openshift-storage-libs/openshiftstoragelibs/openshift_ops.py
+++ b/openshift-storage-libs/openshiftstoragelibs/openshift_ops.py
@@ -2124,3 +2124,23 @@ def oc_create_offline_block_volume_expand_job(
oc_create(hostname, job_data, 'stdin')
return job_name
+
+
+def is_job_complete(hostname, job_name, namespace=""):
+ """Check job completion status
+
+ Args:
+ hostname (str): Hostname on which we want to run command
+ job_name (str): k8s job name
+ namespace (str): k8s namespace name
+ Return:
+ bool
+ """
+
+ cmd = ['oc', 'get', 'jobs', '-o=custom-columns=:.status.succeeded',
+ '--no-headers', job_name]
+
+ cmd += ['-n', namespace] if namespace else []
+
+ out = command.cmd_run(cmd, hostname=hostname)
+ return out == "1"