Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for JobBackoffLimitPerIndex (0.38 sec)

  1. pkg/controller/job/pod_failure_policy_test.go

    									ExitCode: 0,
    								},
    							},
    						},
    					},
    				},
    			},
    			wantJobFailureMessage: nil,
    			wantCountFailed:       true,
    		},
    		"FailIndex rule matched for exit codes; JobBackoffLimitPerIndex enabled": {
    			enableJobBackoffLimitPerIndex: true,
    			podFailurePolicy: &batch.PodFailurePolicy{
    				Rules: []batch.PodFailurePolicyRule{
    					{
    						Action: batch.PodFailurePolicyActionFailIndex,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 22.7K bytes
    - Viewed (0)
  2. pkg/registry/batch/job/strategy.go

    		job.Spec.SuccessPolicy = nil
    	}
    
    	if !utilfeature.DefaultFeatureGate.Enabled(features.JobBackoffLimitPerIndex) {
    		job.Spec.BackoffLimitPerIndex = nil
    		job.Spec.MaxFailedIndexes = nil
    		if job.Spec.PodFailurePolicy != nil {
    			// We drop the FailIndex pod failure policy rules because
    			// JobBackoffLimitPerIndex is disabled.
    			index := 0
    			for _, rule := range job.Spec.PodFailurePolicy.Rules {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 08 16:43:24 UTC 2024
    - 18.4K bytes
    - Viewed (0)
  3. pkg/controller/job/indexed_job_utils_test.go

    			wantResult: false,
    		},
    	}
    	for name, tc := range cases {
    		t.Run(name, func(t *testing.T) {
    			featuregatetesting.SetFeatureGateDuringTest(t, feature.DefaultFeatureGate, features.JobBackoffLimitPerIndex, true)
    			featuregatetesting.SetFeatureGateDuringTest(t, feature.DefaultFeatureGate, features.JobPodFailurePolicy, tc.enableJobPodFailurePolicy)
    			gotResult := isIndexFailed(logger, &tc.job, tc.pod)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 27.9K bytes
    - Viewed (0)
  4. staging/src/k8s.io/api/batch/v1/types_swagger_doc_generated.go

    	"maxFailedIndexes":        "Specifies the maximal number of failed indexes before marking the Job as failed, when backoffLimitPerIndex is set. Once the number of failed indexes exceeds...
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 12:01:28 UTC 2024
    - 27.5K bytes
    - Viewed (0)
  5. staging/src/k8s.io/api/batch/v1/generated.proto

      // be set when Job's completionMode=Indexed, and the Pod's restart
      // policy is Never. The field is immutable.
      // This field is beta-level. It can be used when the `JobBackoffLimitPerIndex`
      // feature gate is enabled (enabled by default).
      // +optional
      optional int32 backoffLimitPerIndex = 12;
    
      // Specifies the maximal number of failed indexes before marking the Job as
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 12:01:28 UTC 2024
    - 29.1K bytes
    - Viewed (0)
  6. pkg/apis/batch/types.go

    	//   running pods are terminated.
    	// - FailIndex: indicates that the pod's index is marked as Failed and will
    	//   not be restarted.
    	//   This value is alpha-level. It can be used when the
    	//   `JobBackoffLimitPerIndex` feature gate is enabled (disabled by default).
    	// - Ignore: indicates that the counter towards the .backoffLimit is not
    	//   incremented and a replacement pod is created.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 12:01:28 UTC 2024
    - 33K bytes
    - Viewed (0)
  7. staging/src/k8s.io/api/batch/v1/types.go

    	//   running pods are terminated.
    	// - FailIndex: indicates that the pod's index is marked as Failed and will
    	//   not be restarted.
    	//   This value is beta-level. It can be used when the
    	//   `JobBackoffLimitPerIndex` feature gate is enabled (enabled by default).
    	// - Ignore: indicates that the counter towards the .backoffLimit is not
    	//   incremented and a replacement pod is created.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 18:37:07 UTC 2024
    - 40.6K bytes
    - Viewed (0)
  8. pkg/features/kube_features.go

    	// owner: @mimowo
    	// kep: https://kep.k8s.io/3850
    	// alpha: v1.28
    	// beta: v1.29
    	//
    	// Allows users to specify counting of failed pods per index.
    	JobBackoffLimitPerIndex featuregate.Feature = "JobBackoffLimitPerIndex"
    
    	// owner: @mimowo
    	// kep: https://kep.k8s.io/4368
    	// alpha: v1.30
    	//
    	// Allows to delegate reconciliation of a Job object to an external controller.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 22:51:23 UTC 2024
    - 45.2K bytes
    - Viewed (0)
  9. pkg/controller/job/indexed_job_utils.go

    	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
    }
    
    type interval struct {
    	First int
    	Last  int
    }
    
    type orderedIntervals []interval
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jul 21 00:44:53 UTC 2023
    - 17.5K bytes
    - Viewed (0)
Back to top