Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for job_finished (0.26 sec)

  1. 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)
  2. 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)
Back to top