Italo Barros
08/12/2021, 3:06 PMThomas Weatherston
08/12/2021, 3:08 PMKevin Kho
@task()
def abc(a):
return a
with Flow("ecs_testing") as flow:
x = abc(1)
y = abc(1, upstream_tasks=[x])
with Flow("ecs_tes") as flow2:
x = abc(1)
y = abc(1)
y.set_upstream(x)
codingtacos
08/12/2021, 3:15 PMflow.add_edge()
no longer used?Kevin Kho
codingtacos
08/12/2021, 3:23 PMItalo Barros
08/12/2021, 3:48 PMKevin Kho
abc()
, I think you can do upstream_tasks=[abc]
, but of course when you do it multiple times, you should probably use the variable assignment. And no you donβt need to return anything. That variable is just a reference for the Task, and the result can be None