Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 52 for completion_mode (0.35 sec)

  1. pkg/registry/batch/cronjob/strategy_test.go

    		JobTemplate: batch.JobTemplateSpec{
    			Spec: batch.JobSpec{
    				Template: validPodTemplateSpec,
    			},
    		},
    	}
    )
    
    func completionModePtr(m batch.CompletionMode) *batch.CompletionMode {
    	return &m
    }
    
    func TestCronJobStrategy(t *testing.T) {
    	ctx := genericapirequest.NewDefaultContext()
    	if !Strategy.NamespaceScoped() {
    		t.Errorf("CronJob must be namespace scoped")
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 15 14:34:53 UTC 2024
    - 12.2K bytes
    - Viewed (0)
  2. tensorflow/cc/saved_model/fingerprinting_chunked_test.cc

                              CreateFingerprintDef(export_dir));
      EXPECT_GT(fingerprint_pb.saved_model_checksum(), 0);
      // We test for multiple fingerprints due to non-determinism when building with
      // different compilation_mode flag options.
      EXPECT_THAT(absl::flat_hash_set<uint64_t>(
                      {906548630859202535U, 9562420523583756263U}),
                  ::testing::Contains(fingerprint_pb.graph_def_program_hash()));
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Wed Sep 06 19:12:29 UTC 2023
    - 2.1K bytes
    - Viewed (0)
  3. staging/src/k8s.io/api/batch/v1/types.go

    	// is possible during upgrades due to version skew, the controller
    	// skips updates for the Job.
    	// +optional
    	CompletionMode *CompletionMode `json:"completionMode,omitempty" protobuf:"bytes,9,opt,name=completionMode,casttype=CompletionMode"`
    
    	// suspend specifies whether the Job controller should create Pods or not. If
    	// a Job is created with suspend set to true, no Pods are created by the Job
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 18:37:07 UTC 2024
    - 40.6K bytes
    - Viewed (0)
  4. pkg/apis/batch/v1/zz_generated.conversion.go

    		return err
    	}
    	out.TTLSecondsAfterFinished = (*int32)(unsafe.Pointer(in.TTLSecondsAfterFinished))
    	out.CompletionMode = (*batch.CompletionMode)(unsafe.Pointer(in.CompletionMode))
    	out.Suspend = (*bool)(unsafe.Pointer(in.Suspend))
    	out.PodReplacementPolicy = (*batch.PodReplacementPolicy)(unsafe.Pointer(in.PodReplacementPolicy))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 20:49:09 UTC 2024
    - 36.6K bytes
    - Viewed (0)
  5. pkg/controller/job/indexed_job_utils.go

    	"k8s.io/kubernetes/pkg/features"
    )
    
    const (
    	completionIndexEnvName = "JOB_COMPLETION_INDEX"
    	unknownCompletionIndex = -1
    )
    
    func isIndexedJob(job *batch.Job) bool {
    	return job.Spec.CompletionMode != nil && *job.Spec.CompletionMode == batch.IndexedCompletion
    }
    
    func hasBackoffLimitPerIndex(job *batch.Job) bool {
    	return feature.DefaultFeatureGate.Enabled(features.JobBackoffLimitPerIndex) && job.Spec.BackoffLimitPerIndex != nil
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jul 21 00:44:53 UTC 2023
    - 17.5K bytes
    - Viewed (0)
  6. pkg/apis/batch/fuzzer/fuzzer.go

    				j.BackoffLimitPerIndex = pointer.Int32(c.Rand.Int31())
    				j.MaxFailedIndexes = pointer.Int32(c.Rand.Int31())
    			}
    			if c.RandBool() {
    				j.BackoffLimit = pointer.Int32(math.MaxInt32)
    			}
    			j.CompletionMode = &mode
    			// We're fuzzing the internal JobSpec type, not the v1 type, so we don't
    			// need to fuzz the nil value.
    			j.Suspend = pointer.Bool(c.RandBool())
    			podReplacementPolicy := batch.TerminatingOrFailed
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 05 17:25:15 UTC 2024
    - 3K bytes
    - Viewed (0)
  7. pkg/apis/batch/types.go

    	// +optional
    	Spec JobSpec
    }
    
    // CompletionMode specifies how Pod completions of a Job are tracked.
    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"
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 12:01:28 UTC 2024
    - 33K bytes
    - Viewed (0)
  8. pkg/apis/batch/zz_generated.deepcopy.go

    	if in.TTLSecondsAfterFinished != nil {
    		in, out := &in.TTLSecondsAfterFinished, &out.TTLSecondsAfterFinished
    		*out = new(int32)
    		**out = **in
    	}
    	if in.CompletionMode != nil {
    		in, out := &in.CompletionMode, &out.CompletionMode
    		*out = new(CompletionMode)
    		**out = **in
    	}
    	if in.Suspend != nil {
    		in, out := &in.Suspend, &out.Suspend
    		*out = new(bool)
    		**out = **in
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 20:49:09 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  9. staging/src/k8s.io/api/batch/v1/zz_generated.deepcopy.go

    	if in.TTLSecondsAfterFinished != nil {
    		in, out := &in.TTLSecondsAfterFinished, &out.TTLSecondsAfterFinished
    		*out = new(int32)
    		**out = **in
    	}
    	if in.CompletionMode != nil {
    		in, out := &in.CompletionMode, &out.CompletionMode
    		*out = new(CompletionMode)
    		**out = **in
    	}
    	if in.Suspend != nil {
    		in, out := &in.Suspend, &out.Suspend
    		*out = new(bool)
    		**out = **in
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 20:49:09 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  10. pkg/controller/job/job_controller.go

    		}
    		return nil
    	}
    
    	if job.Spec.CompletionMode != nil && *job.Spec.CompletionMode != batch.NonIndexedCompletion && *job.Spec.CompletionMode != batch.IndexedCompletion {
    		jm.recorder.Event(&job, v1.EventTypeWarning, "UnknownCompletionMode", "Skipped Job sync because completion mode is unknown")
    		return nil
    	}
    
    	completionMode := getCompletionMode(&job)
    	action := metrics.JobSyncActionReconciling
    
    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