From 245d04454acd4e95640c0f9ca598ac53d340181f Mon Sep 17 00:00:00 2001 From: Nitin Goyal Date: Tue, 17 Nov 2020 11:20:34 +0530 Subject: [Lib] Add lib is_job_complete Lib will check the job completion status Change-Id: Ifbcdc9f18e4d3af5b290982eb4a084459877f91b Signed-off-by: Nitin Goyal --- .../openshiftstoragelibs/openshift_ops.py | 20 ++++++++++++++++++++ 1 file changed, 20 insertions(+) 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" -- cgit