Skip to content

Commit

Permalink
Update for sample retry task
Browse files Browse the repository at this point in the history
  • Loading branch information
erewok committed Dec 12, 2024
1 parent e6a96ca commit 7a7ccdb
Showing 1 changed file with 2 additions and 3 deletions.
5 changes: 2 additions & 3 deletions boilermaker/sample.py
Original file line number Diff line number Diff line change
Expand Up @@ -19,11 +19,10 @@ async def debug_task(state):
STATIC_DEBUG_TASK.payload = {"args": [], "kwargs": {}}


async def debug_task_retry_policy(state, use_default: bool, max_tries=5, delay=30, delay_max=600):
async def debug_task_retry_policy(state, use_default: bool, msg: str = "RETRY TEST", max_tries=5, delay=30, delay_max=600):
"""
This task does nothing
This task does nothing.
"""
msg = "RETRY TEST"
if use_default:
raise RetryException(msg)
raise RetryExceptionDefaultExponential(
Expand Down

0 comments on commit 7a7ccdb

Please sign in to comment.