- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for job_finished (0.18 sec)
-
pkg/controller/job/job_controller_test.go
cases := map[string]struct { job *batch.Job inCache bool }{ "job_does_not_exist": { job: newJob(2, 2, 6, batch.NonIndexedCompletion), }, "orphan": {}, "job_finished": { job: func() *batch.Job { j := newJob(2, 2, 6, batch.NonIndexedCompletion) j.Status.Conditions = append(j.Status.Conditions, batch.JobCondition{ Type: batch.JobComplete,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 15:36:36 UTC 2024 - 229.2K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
return err } jobFinished := !reachedMaxUncountedPods && jm.enactJobFinished(jobCtx.job, jobCtx.finishedCondition) if jobFinished { needsFlush = true } if needsFlush { if _, err := jm.updateStatusHandler(ctx, jobCtx.job); err != nil { return fmt.Errorf("removing uncounted pods from status: %w", err) } if jobFinished {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0)