Skip to content

Commit

Permalink
remove print
Browse files Browse the repository at this point in the history
  • Loading branch information
luke-lombardi committed Nov 28, 2024
1 parent 60d2516 commit 71516e3
Showing 1 changed file with 1 addition and 3 deletions.
4 changes: 1 addition & 3 deletions sdk/src/beta9/runner/taskqueue.py
Original file line number Diff line number Diff line change
Expand Up @@ -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")
Expand Down

0 comments on commit 71516e3

Please sign in to comment.