Fredrik Bengtsson
08/25/2021, 2:24 PM@graph
def g1():
x = op1()
y = op2(x)
@graph(input_defs=[InputDefiniton("start", Nothing)])
def g2():
op3()
@graph
def combined():
g1_res = g1()
g2(g1_res)
However, this resulted in a DagsterInvalidDefinitionError:
@graph 'g2' decorated function does not have parameter(s) 'start' which are in solid's input_defs. Solid functions should only have keyword arguments that mstche input names and, if system information is required, a first parameter named 'context'.
Is there some other way to do this, is it not supported or is it just a bug in the experimental API?
I'm currently running dagster 0.12.6alex
08/25/2021, 2:46 PMgraph
layers all the way to ops
, including Nothing
s.
So you would have to thread the start
through all graph
layers to all the ops
you want to block on.
This is not the most ergonomic, but should allow you to solve your problem.
You can chime in on https://github.com/dagster-io/dagster/issues/4274 with thoughts on what you wish you could doDagster Bot
08/25/2021, 2:47 PMFredrik Bengtsson
08/25/2021, 2:52 PM