Stefan Adelbert
03/08/2022, 4:45 AMop A
produces some data that ops in graph C
depend on (data dependency).
op B1
, op B2
, op B3
, all need to complete before graph C
should start (order-based dependency). op B1
, op B2
, op B3
execution order is not important.
Can anyone suggest a way to build this graph please?alex
03/14/2022, 2:31 PM@graph
def example():
a = op_a()
b1 = op_b1(a)
b2 = op_b2(a)
b3 = op_b3(a)
graph_c(data=a, start_after=[b1, b2, b3])
should work, though if graph_c
is a @graph
, you will need to map the input through to all the inner ops that should block / receive dataStefan Adelbert
03/20/2022, 5:12 AMstart_after
? What is this magick?alex
03/21/2022, 3:16 PMstart_after
in graph_c
to some op that takes something like ins={'start_after': In(Nothing)}
Stefan Adelbert
03/22/2022, 12:23 AMalex
03/22/2022, 2:46 PM