Handle other exceptions from program.

apsis-scheduler · Apr 28, 2021 · 4830191 · 4830191
1 parent 3e066da
commit 4830191
Showing 1 changed file with 17 additions and 0 deletions.
diff --git a/python/apsis/apsis.py b/python/apsis/apsis.py
@@ -202,6 +202,23 @@ def done(future):
                     outputs =exc.outputs,
                 )
 
+            except Exception as exc:
+                # Program raised some other exception.
+                log.error(
+                    f"exception waiting for run: {run.run_id}", exc_info=True)
+                self.run_history.record(
+                    run, f"internal error in program: {exc}")
+                tb = traceback.format_exc().encode()
+                self._transition(
+                    run, run.STATE.error,
+                    outputs ={
+                        "output": Output(
+                            OutputMetadata("traceback", length=len(tb)),
+                            tb
+                        ),
+                    }
+                )
+
             else:
                 # Program ran and completed successfully.
                 self.run_history.record(run, "program success")