diff --git a/lib/galaxy/jobs/runners/kubernetes.py b/lib/galaxy/jobs/runners/kubernetes.py index 56fef20a0ecb..68bbddc81ebb 100644 --- a/lib/galaxy/jobs/runners/kubernetes.py +++ b/lib/galaxy/jobs/runners/kubernetes.py @@ -736,7 +736,10 @@ def check_watched_item(self, job_state): # as probably this means that the k8s API server hasn't # had time to fill in the object status since the # job was created only too recently. - if len(job.obj["status"]) == 0: + # It is possible that k8s didn't account for the status of the pods + # and they are in the uncountedTerminatedPods status. In this + # case we also need to wait a moment + if len(job.obj["status"]) == 0 or job.obj["status"].get("uncountedTerminatedPods"): return job_state if "succeeded" in job.obj["status"]: succeeded = job.obj["status"]["succeeded"]