Domenico Di Gangi
04/22/2022, 4:47 PMZanie
04/22/2022, 4:51 PMwait_for
kwarg is less useful.wait()
before calling the subflowDomenico Di Gangi
04/22/2022, 4:57 PM@task
def task_a():
pass
@task
def task_b():
pass
@flow
def my_flow():
a = task_a()
b = task_b(wait_for=[a])
if task_a fails, task_b does not execute, right?
I am looking for a similar dependency between subflows or a subflow depending on a taskZanie
04/22/2022, 4:59 PMwait_for
argument to your subflow that takes a list of upstream tasks and just not use the data if you don’t need it. We’ll likely support this as a first-class feature in the future. I’ll open an issue for tracking.Domenico Di Gangi
04/22/2022, 5:01 PMZanie
04/22/2022, 5:50 PMwait_for
for flows”Marvin
04/22/2022, 5:50 PM