pdpark
08/01/2023, 9:18 PMchris
08/02/2023, 5:12 AM@graph
def upstream():
...
@graph
def downstream_n(upstream):
...
@job
def run_downstream_in_parallel():
a = upstream()
downstream_1(a)
downstream_2(a)
downstream_3(a)
...
Another option is run status sensors, where you kick off runs to the downstream graphs once the first graph finishes.