- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for hasJobTrackingFinalizer (0.17 sec)
-
pkg/controller/job/indexed_job_utils.go
// has a finalizer (meaning that it is not counted yet). if p.Status.Phase == v1.PodSucceeded && ix != unknownCompletionIndex && ix < int(*job.Spec.Completions) && hasJobTrackingFinalizer(p) { newSucceeded.Insert(ix) } } // List returns the items of the set in order. result := prevIntervals.withOrderedIndexes(sets.List(newSucceeded)) return prevIntervals, result }
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
return } jm.expectations.CreationObserved(logger, jobKey) jm.enqueueSyncJobBatched(logger, job) return } // Otherwise, it's an orphan. // Clean the finalizer. if hasJobTrackingFinalizer(pod) { jm.enqueueOrphanPod(pod) } // Get a list of all matching controllers and sync // them to see if anyone wants to adopt it. // DO NOT observe creation because no controller should be waiting for an
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 err != nil { t.Fatalf("getPodsForJob() error: %v", err) } got := make([]string, len(pods)) var gotFinalizer []string for i, p := range pods { got[i] = p.Name if hasJobTrackingFinalizer(p) { gotFinalizer = append(gotFinalizer, p.Name) } } sort.Strings(got) if diff := cmp.Diff(tc.wantPods, got); diff != "" {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 15:36:36 UTC 2024 - 229.2K bytes - Viewed (0)