Andrew Vaccaro
12/12/2019, 5:28 PMChris White
12/12/2019, 5:30 PMset_upstream
and set_downstream
methods on task objects to specify their upstream / downstream dependenciesAndrew Vaccaro
12/12/2019, 5:36 PMChris White
12/12/2019, 5:38 PMwith Flow("my-flow") as flow:
A.set_dependencies(downstream_tasks=[B], keyword_tasks={"x": param})
B.set_dependencies(downstream_tasks=[C], keyword_tasks={"x": param})
C.set_dependencies(keyword_tasks={"x": param})
where x
is the keyword argument of the task for the parameterAndrew Vaccaro
12/12/2019, 8:02 PMChris White
12/12/2019, 8:33 PMMarvin
12/12/2019, 8:33 PMAndrew Vaccaro
12/12/2019, 9:18 PMChris White
12/12/2019, 9:38 PM