Matthias Queitsch
05/25/2022, 10:14 AMIsaac Harris-Holt
05/25/2022, 10:35 AMStephen Bailey
05/25/2022, 11:29 AM@graph
def g1():
result = op1()
return result
@graph
def g2(depends_on=None):
op2()
@job
def two_graphs():
result = g1()
g2(result)
Matthias Queitsch
05/25/2022, 11:31 AM@op
def launch():
# ...
@graph
def launch_graph():
launch()
@job(run_config=config)
def orchestrate():
launch_graph.alias("g1")()
launch_graph.alias("g2")()
In the run_config, I would configure the different launch commands. g1 need to run before g2 and not in parallel.Stephen Bailey
05/25/2022, 1:46 PMdepends_on
input to the op itselfMatthias Queitsch
05/25/2022, 1:48 PMIsaac Harris-Holt
05/26/2022, 10:30 AM@op
def do_nothing(value):
return
@graph(ins={'deps': In(Nothing)})
def my_graph(deps):
do_nothing(deps)
...