Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for matchPodFailurePolicy (0.18 sec)

  1. pkg/controller/job/indexed_job_utils.go

    	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
    			}
    			isPodFailedCounted = countFailed
    		} else {
    			isPodFailedCounted = 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)
  2. pkg/controller/job/pod_failure_policy_test.go

    		t.Run(name, func(t *testing.T) {
    			featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.JobBackoffLimitPerIndex, tc.enableJobBackoffLimitPerIndex)
    			jobFailMessage, countFailed, action := matchPodFailurePolicy(tc.podFailurePolicy, tc.failedPod)
    			if diff := cmp.Diff(tc.wantJobFailureMessage, jobFailMessage); diff != "" {
    				t.Errorf("Unexpected job failure message: %s", diff)
    			}
    			if tc.wantCountFailed != countFailed {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 22.7K bytes
    - Viewed (0)
Back to top