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

@@ -163,6 +163,22 @@ func (cc *jobcontroller) killPods(jobInfo *apis.JobInfo, podRetainPhase state.Ph
 		classifyAndAddUpPodBaseOnPhase(pod, &pending, &running, &succeeded, &failed, &unknown)
 		calcPodStatus(pod, taskStatusCount)
 	}
+	// update the status for the pods which are not going to be killed
+	for _, pods := range jobInfo.Pods {
+		for _, pod := range pods {
+			_, isPodGoingToBeKilled := podsToKill[pod.Name]
+			if !isPodGoingToBeKilled {
+				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)