Tim Enders
with Flow() as flow:
Kevin Kho
with Flow(...) as flow: a = task_a() b = task_b(upstream_tasks=[a])
with Flow(...) as flow: a = task_a() b = task_b() b.set_upstream(a)
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.