mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-27 13:37:30 +00:00
Merge pull request #126190 from mimowo/job-controller-cleanup
Cleanup Job controller isPodFailed function
This commit is contained in:
commit
7693a7e71a
@ -1901,16 +1901,11 @@ func ensureJobConditionStatus(list []batch.JobCondition, cType batch.JobConditio
|
|||||||
}
|
}
|
||||||
|
|
||||||
func isPodFailed(p *v1.Pod, job *batch.Job) bool {
|
func isPodFailed(p *v1.Pod, job *batch.Job) bool {
|
||||||
if job.Spec.PodFailurePolicy != nil {
|
|
||||||
// Orphan Pods and unschedulable terminating Pods are marked as Failed,
|
|
||||||
// so we only need to check the phase.
|
|
||||||
return p.Status.Phase == v1.PodFailed
|
|
||||||
}
|
|
||||||
if p.Status.Phase == v1.PodFailed {
|
if p.Status.Phase == v1.PodFailed {
|
||||||
return true
|
return true
|
||||||
}
|
}
|
||||||
if onlyReplaceFailedPods(job) {
|
if onlyReplaceFailedPods(job) {
|
||||||
return p.Status.Phase == v1.PodFailed
|
return false
|
||||||
}
|
}
|
||||||
// Count deleted Pods as failures to account for orphan Pods that
|
// Count deleted Pods as failures to account for orphan Pods that
|
||||||
// never have a chance to reach the Failed phase.
|
// never have a chance to reach the Failed phase.
|
||||||
|
Loading…
Reference in New Issue
Block a user