flapili
@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")
Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.