Anh Nguyen
Kevin Kho
with Flow(...) as flow: a = first_task() b = second_task() c = third_task(c_inputs, upstream_tasks=[a,b])
with Flow(...) as flow: a = first_task() b = second_task() c = third_task(c_inputs) c.set_upstream(b)
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.