ref(api): Refine logic for determining pipeline state (#489)

Author: iambriccardo

etl-api/src/k8s/http.rs

@@ -203,13 +203,39 @@ impl HttpK8sClient {
             return false;
         };
 
-        // Check last terminated state for non-zero exit code
-        if let Some(last_state) = &container_status.last_state
-            && let Some(terminated) = &last_state.terminated
-        {
+        let Some(state) = &container_status.state else {
+            return false;
+        };
+
+        // Currently terminated with non-zero exit code.
+        if let Some(terminated) = &state.terminated {
             return terminated.exit_code != 0;
         }
 
+        // Waiting state, we want to distinguish normal waiting reasons from abnormal ones.
+        if let Some(waiting) = &state.waiting {
+            if let Some(reason) = &waiting.reason {
+                match reason.as_str() {
+                    // Crash/restart errors
+                    "CrashLoopBackOff" => return true,
+
+                    // Image-related errors (6 predefined in kubelet)
+                    "ImagePullBackOff"
+                    | "ErrImagePull"
+                    | "ErrImageNeverPull"
+                    | "InvalidImageName"
+                    | "ImageInspectError"
+                    | "RegistryUnavailable" => return true,
+
+                    // Container creation errors
+                    "CreateContainerConfigError" | "CreateContainerError" | "RunContainerError" => {
+                        return true;
+                    }
+                    _ => {}
+                }
+            }
+        }
+
         false
     }
 }