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")