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"