- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for calculateFailedIndexes (0.66 sec)
-
pkg/controller/job/indexed_job_utils.go
result := prevIntervals.withOrderedIndexes(sets.List(newSucceeded)) return prevIntervals, result } // calculateFailedIndexes returns the list of failed indexes in compressed // format (intervals). The list includes indexes already present in // .status.failedIndexes and indexes that failed since the last sync. func calculateFailedIndexes(logger klog.Logger, job *batch.Job, pods []*v1.Pod) *orderedIntervals { var prevIntervals orderedIntervals
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/indexed_job_utils_test.go
}, wantFailedIndexes: []interval{{1, 1}}, }, } for name, tc := range cases { t.Run(name, func(t *testing.T) { failedIndexes := calculateFailedIndexes(logger, &tc.job, tc.pods) if diff := cmp.Diff(&tc.wantFailedIndexes, failedIndexes); diff != "" { t.Errorf("Unexpected failed indexes (-want,+got):\n%s", diff) } }) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 27.9K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0) -
pkg/controller/job/job_controller_test.go
if tc.enableJobBackoffLimitPerIndex && job.Spec.BackoffLimitPerIndex != nil { jobCtx.failedIndexes = calculateFailedIndexes(logger, job, tc.pods) jobCtx.activePods = controller.FilterActivePods(logger, tc.pods) jobCtx.podsWithDelayedDeletionPerIndex = getPodsWithDelayedDeletionPerIndex(logger, jobCtx) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 15:36:36 UTC 2024 - 229.2K bytes - Viewed (0)