From d02b932005566b47419c3b19f0d618d4c6491dbd Mon Sep 17 00:00:00 2001 From: Nathan Freeman Date: Fri, 6 Sep 2024 10:07:25 -0500 Subject: [PATCH] Remove debug --- src/engine/src/core/workflows/WorkflowExecutor.py | 2 -- 1 file changed, 2 deletions(-) diff --git a/src/engine/src/core/workflows/WorkflowExecutor.py b/src/engine/src/core/workflows/WorkflowExecutor.py index 5ab4e236..856e66ae 100644 --- a/src/engine/src/core/workflows/WorkflowExecutor.py +++ b/src/engine/src/core/workflows/WorkflowExecutor.py @@ -401,12 +401,10 @@ def _handle_task_terminal_state(self, task, task_result): # Run the handle_pipeline_terminal_state callback if all tasks are complete. if len(self.state.tasks) == len(self.state.finished): - print("*********** PIPELINE COMPLETED") self._handle_pipeline_terminal_state(event=PIPELINE_COMPLETED) return [] if task_result.status > 0 and task.can_fail == False: - print("*********** PIPELINE FAILED") self._handle_pipeline_terminal_state(event=PIPELINE_FAILED) return []