From 71516e3bab40a21ae93e8b8d5384eef83c8a7afb Mon Sep 17 00:00:00 2001 From: luke-lombardi <33990301+luke-lombardi@users.noreply.github.com> Date: Wed, 27 Nov 2024 21:00:48 -0500 Subject: [PATCH] remove print --- sdk/src/beta9/runner/taskqueue.py | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/sdk/src/beta9/runner/taskqueue.py b/sdk/src/beta9/runner/taskqueue.py index 7b38f81cb..3564f2246 100644 --- a/sdk/src/beta9/runner/taskqueue.py +++ b/sdk/src/beta9/runner/taskqueue.py @@ -337,15 +337,13 @@ def process_tasks(self, channel: Channel) -> None: ) ) if not complete_task_response.ok: - print("hello") raise RunnerException("Unable to end task") if task_status == TaskStatus.Retry: - message = ( + print( complete_task_response.message or f"Retrying task <{task.id}> after {caught_exception} exception" ) - print(message) continue print(f"Task completed <{task.id}>, took {duration}s")