https://prefect.io logo
Title
f

flapili

05/09/2023, 1:41 PM
Hi, do you know how to handle async results from an api cleanly with retry but without raising an exception ?
for now I'm doing
@task(retries=120, retry_delay_seconds=60, cache_expiration=datetime.timedelta(days=1), cache_key_fn=task_input_hash)
async def some_task(job_id: str):
    job = [...]
    if job["status"] == "Success":
        return job
    raise Exception("Not ready yet")