added check for successfull and failed pods in job_controller_actions

Signed-off-by: Kevin Jacob <[email protected]>

Author: kev1N916

pkg/controllers/job/job_controller_actions.go

@@ -97,7 +97,7 @@ func (cc *jobcontroller) killPods(jobInfo *apis.JobInfo, podRetainPhase state.Ph
 	var total int
 
 	podsToKill := make(map[string]*v1.Pod)
-
+	podsToBeRetained := make(map[string]*v1.Pod)
 	if target != nil {
 		if target.Type == state.TargetTypeTask {
 			if targetPods, found := jobInfo.Pods[target.TaskName]; found {
@@ -139,6 +139,8 @@ func (cc *jobcontroller) killPods(jobInfo *apis.JobInfo, podRetainPhase state.Ph
 
 				if !retain {
 					podsToKill[pod.Name] = pod
+				} else {
+					podsToBeRetained[pod.Name] = pod
 				}
 			}
 		}
@@ -164,6 +166,16 @@ func (cc *jobcontroller) killPods(jobInfo *apis.JobInfo, podRetainPhase state.Ph
 		calcPodStatus(pod, taskStatusCount)
 	}
 
+	for _, pod := range podsToBeRetained {
+		if pod.DeletionTimestamp != nil {
+			klog.Infof("Pod <%s/%s> is terminating", pod.Namespace, pod.Name)
+			terminating++
+			continue
+		}
+		classifyAndAddUpPodBaseOnPhase(pod, &pending, &running, &succeeded, &failed, &unknown)
+		calcPodStatus(pod, taskStatusCount)
+	}
+
 	if len(errs) != 0 {
 		klog.Errorf("failed to kill pods for job %s/%s, with err %+v", job.Namespace, job.Name, errs)
 		cc.recorder.Event(job, v1.EventTypeWarning, FailedDeletePodReason,