@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")