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 []