Archie Kennedy
07/03/2023, 11:27 AMVarun P
07/03/2023, 12:37 PMRetryPolicy
.
custom_retry = RetryPolicy(
max_retries=2,
delay=1800,
backoff=Backoff.EXPONENTIAL,
jitter=Jitter.PLUS_MINUS,
)
@op(retry_policy=custom_retry)
def my_op(context,cred_id):
pass
Archie Kennedy
07/03/2023, 12:50 PMArchie Kennedy
07/03/2023, 12:51 PM@job(tags={"dagster/max_retries": 3})
def sample_job():
pass
Varun P
07/03/2023, 12:52 PM@job(tags={"dagster/max_retries": 3,"dagster/delay":1800,"dagster/backoff: Backoff.Exponential})
def sample_job():
pass
Have you tried if this works?Archie Kennedy
07/03/2023, 12:53 PMArchie Kennedy
07/03/2023, 1:13 PMArchie Kennedy
07/05/2023, 12:02 PMArchie Kennedy
07/05/2023, 12:02 PM@job(tags={"dagster/max_retries": 3})