Jeremy Savage
05/11/2022, 12:26 PM@task(max_retries=200)
def some_task():
if helpers.test_if_job_done() is False:
raise RETRY(
"Work not done yet, retrying in 20 seconds.",
start_time=pendulum.now().add(seconds=20),
)
TIAAnna Geller
05/11/2022, 12:35 PM@task
def some_task():
if (
helpers.test_if_job_done() is False
and prefect.context.get("task_run_count") < 200
):
raise RETRY(
"Work not done yet, retrying in 20 seconds.",
start_time=pendulum.now().add(seconds=20),
)
Jeremy Savage
05/11/2022, 12:46 PM@task
def some_task():
if helpers.test_if_job_done() is False:
if prefect.context.get("task_run_count") < 200:
raise RETRY(
"Work not done yet, retrying in 20 seconds.",
start_time=pendulum.now().add(seconds=20),
)
else:
raise FAIL()
Anna Geller
05/11/2022, 1:09 PM