flapili
05/09/2023, 1:41 PM@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")