ober
04/18/2023, 7:45 AMdef node_a():
var = f" node_a "
return var
@task
def start():
return node_a()
@task
def single():
return node_a()
@task
def node_b(i):
var = f"{i} node_b "
return var
@task
def node_c(i, j):
var = f"{i}-{j} node_c "
return var
@flow
def part() :
x = single()
a = start()
b = node_b(a)
c = node_c.submit(x, b, wait_for=[x, b])
return
@flow(name="complex_dag")
def main():
ret = part()
print(ret)
Zanie
Zanie
single
and start
and aren’t passing futures around, we’re just doing the best we canZanie
wait_for
does nothing in your example since you’re passing data (not futures)ober
04/19/2023, 1:34 AM@flow
def part() :
x = single.submit()
a = start()
b = node_b(a)
c = node_c(x, b)
return