- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for matchPodFailurePolicy (0.31 sec)
-
pkg/controller/job/pod_failure_policy.go
*/ package job import ( "fmt" batch "k8s.io/api/batch/v1" v1 "k8s.io/api/core/v1" "k8s.io/apiserver/pkg/util/feature" "k8s.io/kubernetes/pkg/features" ) // matchPodFailurePolicy returns information about matching a given failed pod // against the pod failure policy rules. The information is represented as an // - optional job failure message (present in case the pod matched a 'FailJob' rule),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 18 20:44:11 UTC 2023 - 5.5K bytes - Viewed (0) -
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) -
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) -
pkg/controller/job/job_controller.go
result := len(failedPods) if feature.DefaultFeatureGate.Enabled(features.JobPodFailurePolicy) && jobCtx.job.Spec.PodFailurePolicy != nil { for _, p := range failedPods { _, countFailed, _ := matchPodFailurePolicy(jobCtx.job.Spec.PodFailurePolicy, p) if !countFailed { result-- } } } return result } // deleteJobPods deletes the pods, returns the number of successful removals
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (1)