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).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