fix bug for check PodPending (#1021)

kubeflow · Jun 3, 2019 · d0b973b · d0b973b
1 parent b123a75
commit d0b973b
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/pkg/controller.v1/tensorflow/controller.go b/pkg/controller.v1/tensorflow/controller.go
@@ -514,7 +514,7 @@ func (tc *TFController) pastBackoffLimit(tfjob *tfv1.TFJob, pods []*v1.Pod) (boo
 		}
 		for i := range pods {
 			po := pods[i]
-			if po.Status.Phase == v1.PodRunning || po.Status.Phase != v1.PodPending {
+			if po.Status.Phase == v1.PodRunning || po.Status.Phase == v1.PodPending {
 				for j := range po.Status.InitContainerStatuses {
 					stat := po.Status.InitContainerStatuses[j]
 					result += stat.RestartCount

diff --git a/pkg/controller.v1beta2/tensorflow/controller.go b/pkg/controller.v1beta2/tensorflow/controller.go
@@ -505,7 +505,7 @@ func (tc *TFController) pastBackoffLimit(tfjob *tfv1beta2.TFJob, pods []*v1.Pod)
 		}
 		for i := range pods {
 			po := pods[i]
-			if po.Status.Phase == v1.PodRunning || po.Status.Phase != v1.PodPending {
+			if po.Status.Phase == v1.PodRunning || po.Status.Phase == v1.PodPending {
 				for j := range po.Status.InitContainerStatuses {
 					stat := po.Status.InitContainerStatuses[j]
 					result += stat.RestartCount