Anh Nguyen
12/09/2021, 3:42 AMKevin Kho
with Flow(...) as flow:
a = first_task()
b = second_task()
c = third_task(c_inputs, upstream_tasks=[a,b])
You can also do:
with Flow(...) as flow:
a = first_task()
b = second_task()
c = third_task(c_inputs)
c.set_upstream(b)
Anh Nguyen
12/09/2021, 3:53 AM