[Sparkjob] Fix termination time resolution (#1436)

mlrun · Oct 19, 2021 · 7a04809 · 7a04809
1 parent a5cd62c
commit 7a04809
Showing 1 changed file with 12 additions and 5 deletions.
diff --git a/mlrun/runtimes/sparkjob/abstract.py b/mlrun/runtimes/sparkjob/abstract.py
@@ -626,11 +626,18 @@ def _resolve_crd_object_status_info(
         )
         completion_time = None
         if in_terminal_state:
-            completion_time = datetime.fromisoformat(
-                crd_object.get("status", {})
-                .get("terminationTime")
-                .replace("Z", "+00:00")
-            )
+            if crd_object.get("status", {}).get("terminationTime"):
+                completion_time = datetime.fromisoformat(
+                    crd_object.get("status", {})
+                    .get("terminationTime")
+                    .replace("Z", "+00:00")
+                )
+            else:
+                completion_time = datetime.fromisoformat(
+                    crd_object.get("status", {})
+                    .get("lastSubmissionAttemptTime")
+                    .replace("Z", "+00:00")
+                )
         return in_terminal_state, completion_time, desired_run_state
 
     def _update_ui_url(