Marwan Sarieddine
07/10/2020, 3:36 PMnicholas
07/10/2020, 3:38 PMupstream_tasks
kwarg to a copy of the Task instance. You can read more about upstream tasks
here: https://docs.prefect.io/api/latest/core/task.html#task-2Marwan Sarieddine
07/10/2020, 3:38 PMwith Flow("test-flow"):
f1 = task1a()
task1b(f1)
g1 = task2a()
task2b(g1)
task1a
will always be executed before task2a
in the simple local non-parallel run - correct ?nicholas
07/10/2020, 4:21 PMupstream_tasks=[f1]
in the constructor for task2a
like this:
with Flow("test-flow") as flow:
f1 = task1a()
task1b(f1)
g1 = task2a(upstream_tasks=[f1])
task2b(g1)
Marwan Sarieddine
07/10/2020, 4:21 PMnicholas
07/10/2020, 4:21 PMMarwan Sarieddine
07/10/2020, 4:24 PM