Tony Popov
class Result: pass @task async def my_task_1(arg: str) -> Result: ... @task async def my_task_2(arg: Result) -> None: ...
await my_task_1('arg')
my_task_1('arg')
task_result = await my_task.submit('arg') result = await task_result.result() await my_task_2.submit(result)
Bianca Hoch
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.