From ea82a2d5a6d1276d6d41af5ad678eda77a9025bd Mon Sep 17 00:00:00 2001
From: Nathan Freeman <nathan.dean.freeman@gmail.com>
Date: Tue, 14 Nov 2023 14:15:22 -0600
Subject: [PATCH] terminate workflow executor on pipeline fail

---
 src/engine/src/core/workflows/executors/WorkflowExecutor.py | 1 +
 1 file changed, 1 insertion(+)

diff --git a/src/engine/src/core/workflows/executors/WorkflowExecutor.py b/src/engine/src/core/workflows/executors/WorkflowExecutor.py
index e8fd72a9..6e3c01c6 100644
--- 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"