Skip to content

Commit

Permalink
Try for cleaner messaging when retry is published
Browse files Browse the repository at this point in the history
  • Loading branch information
erewok committed Dec 12, 2024
1 parent 3e3bbf4 commit e6a96ca
Showing 1 changed file with 4 additions and 6 deletions.
10 changes: 4 additions & 6 deletions boilermaker/app.py
Original file line number Diff line number Diff line change
Expand Up @@ -292,12 +292,10 @@ async def message_handler(

delay = task.get_next_delay()
warn_msg = (
"Event retry requested. Publishing retry:"
f"[ {task.function_name=}"
f" {retry.msg=}"
f" {task.attempts.attempts=}"
f" {delay=}"
f" {sequence_number=} ]"
f"[{sequence_number=}] {retry.msg}. Publishing retry: "
f"<function={task.function_name}>, "
f" attempts={task.attempts.attempts}, "
f" {delay=}>"
)
logger.warning(warn_msg)
await self.publish_task(
Expand Down

0 comments on commit e6a96ca

Please sign in to comment.