Emilja Dankevičiūtė12/21/2022, 7:31 AM
would probably work. But I'm also interested in controlling delay between retries..
Jason12/21/2022, 2:04 PM
@op( retry_policy=RetryPolicy( max_retries=3, delay=0.2, # 200ms backoff=Backoff.EXPONENTIAL, jitter=Jitter.PLUS_MINUS, ) ) def even_better(): fails_sometimes()
Emilja Dankevičiūtė12/21/2022, 2:22 PM
. We have a job that materializes assets via
. You can pass op retry policy (the one that you mentioned) when you define custom job via
decorator. But not for
as far as I can tell.
Jason12/21/2022, 2:40 PM
via @asset (api link included). On the job level, I’m not sure if you can control the delay but there is a
tag which I don’t use on asset jobs but probably still works. https://docs.dagster.io/_apidocs/assets
Emilja Dankevičiūtė12/22/2022, 7:05 AM
, so no decorator. And I want to set retries based on the job and not on the asset, if possible.