diff --git a/pkg/controller/job/job_controller.go b/pkg/controller/job/job_controller.go index 77e1b642be8..c7379131ffe 100644 --- a/pkg/controller/job/job_controller.go +++ b/pkg/controller/job/job_controller.go @@ -1453,17 +1453,18 @@ func (jm *Controller) manageJob(ctx context.Context, job *batch.Job, jobCtx *syn diff = int32(MaxPodCreateDeletePerSync) } + var indexesToAdd []int + if isIndexedJob(job) { + indexesToAdd = firstPendingIndexes(jobCtx, int(diff), int(*job.Spec.Completions)) + diff = int32(len(indexesToAdd)) + } + jm.expectations.ExpectCreations(logger, jobKey, int(diff)) errCh := make(chan error, diff) logger.V(4).Info("Too few pods running", "key", jobKey, "need", wantActive, "creating", diff) wait := sync.WaitGroup{} - var indexesToAdd []int - if isIndexedJob(job) { - indexesToAdd = firstPendingIndexes(jobCtx, int(diff), int(*job.Spec.Completions)) - diff = int32(len(indexesToAdd)) - } active += diff podTemplate := job.Spec.Template.DeepCopy()