Alfie
07/16/2020, 12:20 PMjosh
07/16/2020, 12:22 PMIn [4]: with Flow('dep') as flow:
...: a = a()
...: b = b()
...: b.set_upstream(a)
(there’s also .set_downstream()
)Alfie
07/16/2020, 12:23 PMjosh
07/16/2020, 12:23 PMIn [1]: from prefect import task, Flow
In [2]: @task
...: def a():
...: pass
...:
In [3]: @task
...: def b():
...: pass
...:
In [4]: with Flow('dep') as flow:
...: a = a()
...: b = b()
...: b.set_upstream(a)
Alfie
07/16/2020, 12:24 PMjosh
07/16/2020, 12:25 PMAlfie
07/16/2020, 12:27 PM