- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for isJobFinished (0.11 sec)
-
pkg/registry/batch/job/strategy.go
// down a Job. isIndexed := ptr.Deref(newJob.Spec.CompletionMode, batch.NonIndexedCompletion) == batch.IndexedCompletion isJobFinishedChanged := batchvalidation.IsJobFinished(oldJob) != batchvalidation.IsJobFinished(newJob) isJobCompleteChanged := batchvalidation.IsJobComplete(oldJob) != batchvalidation.IsJobComplete(newJob) isJobFailedChanged := batchvalidation.IsJobFailed(oldJob) != batchvalidation.IsJobFailed(newJob)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 16:43:24 UTC 2024 - 18.4K bytes - Viewed (0) -
pkg/controller/ttlafterfinished/ttlafterfinished_controller.go
tc.enqueueAfter(job, *t) return nil, nil } // needsCleanup checks whether a Job has finished and has a TTL set. func needsCleanup(j *batch.Job) bool { return j.Spec.TTLSecondsAfterFinished != nil && jobutil.IsJobFinished(j) } func getFinishAndExpireTime(j *batch.Job) (*time.Time, *time.Time, error) { if !needsCleanup(j) { return nil, nil, fmt.Errorf("job %s/%s should not be cleaned up", j.Namespace, j.Name) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 07 23:59:28 UTC 2024 - 10.4K bytes - Viewed (0) -
pkg/controller/cronjob/cronjob_controllerv2.go
updateStatus := false childrenJobs := make(map[types.UID]bool) for _, j := range jobs { childrenJobs[j.ObjectMeta.UID] = true found := inActiveList(cronJob, j.ObjectMeta.UID) if !found && !jobutil.IsJobFinished(j) { cjCopy, err := jm.cronJobControl.GetCronJob(ctx, cronJob.Namespace, cronJob.Name) if err != nil { return nil, updateStatus, err } if inActiveList(cjCopy, j.ObjectMeta.UID) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 29.2K bytes - Viewed (0)