Luca Schneider
11/14/2022, 1:19 PM@flow
def flow():
f1 = subflow1()
f2 = subflow2()
data1 = task1.submit(wait_for=[f1, f2])
data2 = task2().submit()
data3 = task3.submit(data1, data2, wait_for=[data1, data2])
if data3.result():
data4 = task4.submit(data3, wait_for=[data3])
task5.submit(data4, wait_for=[data4])
else:
pass
Bianca Hoch
11/16/2022, 10:13 PM