Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for isPodFailed (0.07 sec)

  1. pkg/controller/job/indexed_job_utils.go

    	result := prevIntervals.withOrderedIndexes(sets.List(newFailed))
    	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)
    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/job_controller.go

    	for _, pod := range jobCtx.pods {
    		if !hasJobTrackingFinalizer(pod) || jobCtx.expectedRmFinalizers.Has(string(pod.UID)) {
    			// This pod was processed in a previous sync.
    			continue
    		}
    		considerPodFailed := isPodFailed(pod, jobCtx.job)
    		if !canRemoveFinalizer(logger, jobCtx, pod, considerPodFailed) {
    			continue
    		}
    		podsToRemoveFinalizer = append(podsToRemoveFinalizer, pod)
    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