- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for isPodFailed (0.07 sec)
-
pkg/controller/job/indexed_job_utils.go
result := prevIntervals.withOrderedIndexes(sets.List(newFailed)) return &result } func isIndexFailed(logger klog.Logger, job *batch.Job, pod *v1.Pod) bool { isPodFailedCounted := false if isPodFailed(pod, job) { if feature.DefaultFeatureGate.Enabled(features.JobPodFailurePolicy) && job.Spec.PodFailurePolicy != nil { _, countFailed, action := matchPodFailurePolicy(job.Spec.PodFailurePolicy, pod)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 21 00:44:53 UTC 2023 - 17.5K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
for _, pod := range jobCtx.pods { if !hasJobTrackingFinalizer(pod) || jobCtx.expectedRmFinalizers.Has(string(pod.UID)) { // This pod was processed in a previous sync. continue } considerPodFailed := isPodFailed(pod, jobCtx.job) if !canRemoveFinalizer(logger, jobCtx, pod, considerPodFailed) { continue } podsToRemoveFinalizer = append(podsToRemoveFinalizer, pod)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0)