terminate workflow executor on pipeline fail

tapis-project · Nov 14, 2023 · ea82a2d · ea82a2d
1 parent 9097280
commit ea82a2d
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/engine/src/core/workflows/executors/WorkflowExecutor.py b/src/engine/src/core/workflows/executors/WorkflowExecutor.py
@@ -347,6 +347,7 @@ def _on_pipeline_terminal_state(self, event=None, message=""):
             event = PIPELINE_FAILED if len(self.state.failed) > 0 else PIPELINE_COMPLETED
 
         if event == PIPELINE_FAILED:
+            self.terminate()
             self._deregister_all_executors()
 
         msg = "COMPLETED"