Daniel Nilsen
Anna Geller
upstream_tasks
from prefect import task, Flow @task def task_1(): pass @task def task_2(): pass @task def task_3(): pass with Flow("flow_with_dependencies") as flow: t1 = task_1() t2 = task_2(upstream_tasks=[t1]) t3 = task_3(upstream_tasks=[t2])
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.