Mansour Zayer
08/31/2022, 7:05 PM../flow_1.py
@task(my_task)
def my_task(param)
.................................
from flow_1.py import my_task
../flow_2.py
@Flow(some_flow):
my_task(param_1)
my_task(param_2, upstream_tasks=[my_task])
Since the 2 tasks in my Flow in flow_2 have the same name, would upstream_tasks
work? Is there a better way to do this?
Thank youfrom flow_1.py import my_task
../flow_2.py
@Flow(some_flow):
task_1 = my_task(param_1)
task_2 = my_task(param_2, upstream_tasks=[task_1])
🤦Bianca Hoch
08/31/2022, 9:18 PM