Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for NonIndexedCompletion (0.2 sec)

  1. pkg/apis/batch/v1/defaults_test.go

    			expected: &batchv1.Job{
    				Spec: batchv1.JobSpec{
    					Completions:    pointer.Int32(1),
    					Parallelism:    pointer.Int32(1),
    					BackoffLimit:   pointer.Int32(6),
    					CompletionMode: completionModePtr(batchv1.NonIndexedCompletion),
    					Suspend:        pointer.Bool(false),
    					ManualSelector: pointer.Bool(false),
    					PodFailurePolicy: &batchv1.PodFailurePolicy{
    						Rules: []batchv1.PodFailurePolicyRule{
    							{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 20.8K bytes
    - Viewed (0)
  2. pkg/api/job/warnings_test.go

    	}{
    		"valid NonIndexed": {
    			spec: &batch.JobSpec{
    				CompletionMode: completionModePtr(batch.NonIndexedCompletion),
    				Template:       validPodTemplate,
    			},
    		},
    		"NondIndexed with high completions and parallelism": {
    			spec: &batch.JobSpec{
    				CompletionMode: completionModePtr(batch.NonIndexedCompletion),
    				Template:       validPodTemplate,
    				Parallelism:    pointer.Int32(1_000_000_000),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 14 14:38:42 UTC 2023
    - 3.6K bytes
    - Viewed (0)
  3. pkg/controller/job/job_controller_test.go

    	jm.podStoreSynced = alwaysReady
    	jm.jobStoreSynced = alwaysReady
    
    	job1 := newJob(1, 1, 6, batch.NonIndexedCompletion)
    	job1.Name = "job1"
    	job2 := newJob(1, 1, 6, batch.NonIndexedCompletion)
    	job2.Name = "job2"
    	job3 := newJob(1, 1, 6, batch.NonIndexedCompletion)
    	job3.Name = "job3"
    	job3.Spec.Selector.MatchLabels = map[string]string{"other": "labels"}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 15:36:36 UTC 2024
    - 229.2K bytes
    - Viewed (0)
  4. pkg/apis/batch/fuzzer/fuzzer.go

    			backoffLimit := int32(c.Rand.Int31())
    			j.Completions = &completions
    			j.Parallelism = &parallelism
    			j.BackoffLimit = &backoffLimit
    			j.ManualSelector = pointer.Bool(c.RandBool())
    			mode := batch.NonIndexedCompletion
    			if c.RandBool() {
    				mode = batch.IndexedCompletion
    				j.BackoffLimitPerIndex = pointer.Int32(c.Rand.Int31())
    				j.MaxFailedIndexes = pointer.Int32(c.Rand.Int31())
    			}
    			if c.RandBool() {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 05 17:25:15 UTC 2024
    - 3K bytes
    - Viewed (0)
  5. pkg/apis/batch/v1/defaults.go

    		}
    	}
    	labels := obj.Spec.Template.Labels
    	if labels != nil && len(obj.Labels) == 0 {
    		obj.Labels = labels
    	}
    	if obj.Spec.CompletionMode == nil {
    		mode := batchv1.NonIndexedCompletion
    		obj.Spec.CompletionMode = &mode
    	}
    	if obj.Spec.Suspend == nil {
    		obj.Spec.Suspend = utilpointer.Bool(false)
    	}
    	if obj.Spec.PodFailurePolicy != nil {
    		for _, rule := range obj.Spec.PodFailurePolicy.Rules {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Oct 11 20:51:40 UTC 2023
    - 3.1K bytes
    - Viewed (0)
  6. pkg/apis/batch/validation/validation.go

    		}
    	}
    	if spec.CompletionMode != nil {
    		if *spec.CompletionMode != batch.NonIndexedCompletion && *spec.CompletionMode != batch.IndexedCompletion {
    			allErrs = append(allErrs, field.NotSupported(fldPath.Child("completionMode"), spec.CompletionMode, []batch.CompletionMode{batch.NonIndexedCompletion, batch.IndexedCompletion}))
    		}
    		if *spec.CompletionMode == batch.IndexedCompletion {
    			if spec.Completions == nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 08 16:43:24 UTC 2024
    - 51.2K bytes
    - Viewed (0)
  7. pkg/registry/batch/job/strategy_test.go

    					Completions:    ptr.To[int32](5),
    					CompletionMode: completionModePtr(batch.NonIndexedCompletion),
    				},
    			},
    			newJob: &batch.Job{
    				ObjectMeta: validObjectMeta,
    				Spec: batch.JobSpec{
    					Completions:    ptr.To[int32](5),
    					CompletionMode: completionModePtr(batch.NonIndexedCompletion),
    				},
    				Status: batch.JobStatus{
    					StartTime:        &now,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 101.5K bytes
    - Viewed (0)
  8. pkg/controller/job/indexed_job_utils.go

    	return len(bci)
    }
    
    func completionModeStr(job *batch.Job) string {
    	if job.Spec.CompletionMode != nil {
    		return string(*job.Spec.CompletionMode)
    	}
    	return string(batch.NonIndexedCompletion)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jul 21 00:44:53 UTC 2023
    - 17.5K bytes
    - Viewed (0)
  9. pkg/registry/batch/job/strategy.go

    		// below .spec.completions, however, this it is ok if the
    		// status.completedIndexes go beyond completions just after a user scales
    		// down a Job.
    		isIndexed := ptr.Deref(newJob.Spec.CompletionMode, batch.NonIndexedCompletion) == batch.IndexedCompletion
    
    		isJobFinishedChanged := batchvalidation.IsJobFinished(oldJob) != batchvalidation.IsJobFinished(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)
  10. pkg/apis/batch/types.go

    type CompletionMode string
    
    const (
    	// NonIndexedCompletion is a Job completion mode. In this mode, the Job is
    	// considered complete when there have been .spec.completions
    	// successfully completed Pods. Pod completions are homologous to each other.
    	NonIndexedCompletion CompletionMode = "NonIndexed"
    
    	// IndexedCompletion is a Job completion mode. In this mode, the Pods of a
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 12:01:28 UTC 2024
    - 33K bytes
    - Viewed (0)
Back to top