Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 18 for JobPodFailurePolicy (0.35 sec)

  1. pkg/controller/job/indexed_job_utils_test.go

    				},
    			},
    			pod:        buildPod().indexFailureCount("1").phase(v1.PodFailed).index("1").trackingFinalizer().Pod,
    			wantResult: true,
    		},
    		"matching FailIndex pod failure policy; JobPodFailurePolicy enabled": {
    			enableJobPodFailurePolicy: true,
    			job: batch.Job{
    				Spec: batch.JobSpec{
    					Completions:          ptr.To[int32](2),
    					BackoffLimitPerIndex: ptr.To[int32](1),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 27.9K bytes
    - Viewed (0)
  2. pkg/registry/batch/job/strategy_test.go

    					Template:             validPodTemplateSpec,
    					BackoffLimitPerIndex: nil,
    					MaxFailedIndexes:     nil,
    				},
    			},
    		},
    		"update job with a new field; updated when JobPodFailurePolicy enabled": {
    			enableJobPodFailurePolicy: true,
    			job: batch.Job{
    				ObjectMeta: getValidObjectMeta(0),
    				Spec: batch.JobSpec{
    					Selector:         validSelector,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 101.5K bytes
    - Viewed (0)
  3. pkg/controller/job/indexed_job_utils.go

    	return &result
    }
    
    func isIndexFailed(logger klog.Logger, job *batch.Job, pod *v1.Pod) bool {
    	isPodFailedCounted := false
    	if isPodFailed(pod, job) {
    		if feature.DefaultFeatureGate.Enabled(features.JobPodFailurePolicy) && job.Spec.PodFailurePolicy != nil {
    			_, countFailed, action := matchPodFailurePolicy(job.Spec.PodFailurePolicy, pod)
    			if action != nil && *action == batch.PodFailurePolicyActionFailIndex {
    				return true
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jul 21 00:44:53 UTC 2023
    - 17.5K bytes
    - Viewed (0)
  4. pkg/registry/batch/job/strategy.go

    	job := obj.(*batch.Job)
    	generateSelectorIfNeeded(job)
    	job.Status = batch.JobStatus{}
    
    	job.Generation = 1
    
    	if !utilfeature.DefaultFeatureGate.Enabled(features.JobPodFailurePolicy) {
    		job.Spec.PodFailurePolicy = nil
    	}
    	if !utilfeature.DefaultFeatureGate.Enabled(features.JobManagedBy) {
    		job.Spec.ManagedBy = nil
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 08 16:43:24 UTC 2024
    - 18.4K bytes
    - Viewed (0)
  5. pkg/controller/job/job_controller.go

    	// So, the job-controller evaluates the podFailurePolicy only when the Job doesn't have the SuccessCriteriaMet condition.
    	if jobCtx.finishedCondition == nil && feature.DefaultFeatureGate.Enabled(features.JobPodFailurePolicy) {
    		if failureTargetCondition := findConditionByType(job.Status.Conditions, batch.JobFailureTarget); failureTargetCondition != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 10 23:56:37 UTC 2024
    - 77.6K bytes
    - Viewed (0)
  6. pkg/features/kube_features.go

    	// kep: https://kep.k8s.io/3329
    	// alpha: v1.25
    	// beta: v1.26
    	//
    	// Allow users to specify handling of pod failures based on container exit codes
    	// and pod conditions.
    	JobPodFailurePolicy featuregate.Feature = "JobPodFailurePolicy"
    
    	// owner: @kannon92
    	// kep : https://kep.k8s.io/3939
    	// alpha: v1.28
    	// beta: v1.29
    	//
    	// Allow users to specify recreating pods of a job only when
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 22:51:23 UTC 2024
    - 45.2K bytes
    - Viewed (0)
  7. pkg/controller/job/job_controller_test.go

    			featuregatetesting.SetFeatureGateDuringTest(t, feature.DefaultFeatureGate, features.JobPodFailurePolicy, tc.jobPodFailurePolicy)
    			// job manager setup
    			clientSet := clientset.NewForConfigOrDie(&restclient.Config{Host: "", ContentConfig: restclient.ContentConfig{GroupVersion: &schema.GroupVersion{Group: "", Version: "v1"}}})
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 15:36:36 UTC 2024
    - 229.2K bytes
    - Viewed (0)
  8. common-protos/k8s.io/api/batch/v1/generated.proto

      // checked against the backoffLimit. This field cannot be used in combination
      // with restartPolicy=OnFailure.
      //
      // This field is alpha-level. To use this field, you must enable the
      // `JobPodFailurePolicy` feature gate (disabled by default).
      // +optional
      optional PodFailurePolicy podFailurePolicy = 11;
    
      // Specifies the number of retries before marking this job failed.
      // Defaults to 6
      // +optional
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 21.1K bytes
    - Viewed (0)
  9. staging/src/k8s.io/api/batch/v1/types_swagger_doc_generated.go

    	"successPolicy":           "successPolicy specifies the policy when the Job can be declared as succeeded. If empty, the default behavior applies - the Job is declared as succeeded only when...
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 12:01:28 UTC 2024
    - 27.5K bytes
    - Viewed (0)
  10. staging/src/k8s.io/api/batch/v1/generated.proto

      // checked against the backoffLimit. This field cannot be used in combination
      // with restartPolicy=OnFailure.
      //
      // This field is beta-level. It can be used when the `JobPodFailurePolicy`
      // feature gate is enabled (enabled by default).
      // +optional
      optional PodFailurePolicy podFailurePolicy = 11;
    
      // successPolicy specifies the policy when the Job can be declared as succeeded.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 12:01:28 UTC 2024
    - 29.1K bytes
    - Viewed (0)
Back to top