File tree Expand file tree Collapse file tree 1 file changed +6
-3
lines changed
Expand file tree Collapse file tree 1 file changed +6
-3
lines changed Original file line number Diff line number Diff line change 2020LWS_PLURAL = "leaderworkersets"
2121
2222
23-
2423def _get_lws_version (group = LWS_GROUP ):
2524 """Get the preferred version for the LeaderWorkerSet API."""
2625 _load_kube_config ()
@@ -159,7 +158,9 @@ def wait_for_job(
159158 # Pod might not be created yet
160159 pod = None
161160 else :
162- raise RuntimeError (f"Failed to read leader pod status: { e .reason } " ) from e
161+ raise RuntimeError (
162+ f"Failed to read leader pod status: { e .reason } "
163+ ) from e
163164
164165 if pod is not None and pod .status .container_statuses :
165166 container_status = pod .status .container_statuses [0 ]
@@ -179,7 +180,9 @@ def wait_for_job(
179180 # Check last state (in case it restarted)
180181 if container_status .last_state .terminated :
181182 if container_status .last_state .terminated .exit_code == 0 :
182- logger .info (f"[REMOTE] Job { job_name } completed successfully (restarted)" )
183+ logger .info (
184+ f"[REMOTE] Job { job_name } completed successfully (restarted)"
185+ )
183186 return "success"
184187 else :
185188 _print_pod_logs (core_v1 , job_name , namespace )
You can’t perform that action at this time.
0 commit comments