File tree Expand file tree Collapse file tree 1 file changed +7
-5
lines changed Expand file tree Collapse file tree 1 file changed +7
-5
lines changed Original file line number Diff line number Diff line change @@ -55,15 +55,17 @@ def create_job(api_instance, job):
55
55
api_response = api_instance .create_namespaced_job (
56
56
body = job ,
57
57
namespace = "default" )
58
- # Need to wait for a second for the job status to update
59
- sleep (1 )
60
58
print ("Job created. status='%s'" % str (get_job_status (api_instance )))
61
59
62
60
63
61
def get_job_status (api_instance ):
64
- api_response = api_instance .read_namespaced_job_status (
65
- name = JOB_NAME ,
66
- namespace = "default" )
62
+ job_completed = False
63
+ while not job_completed :
64
+ api_response = api_instance .read_namespaced_job_status (
65
+ name = JOB_NAME ,
66
+ namespace = "default" )
67
+ if api_response .status .succeeded is not None or api_response .status .failed is not None :
68
+ job_completed = True
67
69
return api_response .status
68
70
69
71
You can’t perform that action at this time.
0 commit comments