fix: worker restart

Signed-off-by: 张启航 <[email protected]>
goodrain · Dec 27, 2024 · 0b13dad · 0b13dad
1 parent 1f309f2
commit 0b13dad
Showing 1 changed file with 10 additions and 8 deletions.
diff --git a/worker/util/pod.go b/worker/util/pod.go
@@ -75,14 +75,16 @@ func DescribePodStatus(clientset kubernetes.Interface, pod *corev1.Pod, podStatu
 		for _, cstatus := range pod.Status.ContainerStatuses {
 			for _, OwnerReference := range pod.OwnerReferences {
 				if OwnerReference.Kind == "Job" {
-					if cstatus.State.Terminated.Reason == "Completed" {
-						podStatus.Type = pb.PodStatus_SUCCEEDED
-					}
-					if cstatus.State.Terminated.Reason == "DeadlineExceeded" {
-						podStatus.Type = pb.PodStatus_FAILED
-					}
-					if cstatus.State.Terminated.Reason == "Error" {
-						podStatus.Type = pb.PodStatus_ABNORMAL
+					if cstatus.State.Terminated != nil {
+						if cstatus.State.Terminated.Reason == "Completed" {
+							podStatus.Type = pb.PodStatus_SUCCEEDED
+						}
+						if cstatus.State.Terminated.Reason == "DeadlineExceeded" {
+							podStatus.Type = pb.PodStatus_FAILED
+						}
+						if cstatus.State.Terminated.Reason == "Error" {
+							podStatus.Type = pb.PodStatus_ABNORMAL
+						}
 					}
 				}
 			}