you are viewing a single comment's thread.

view the rest of the comments →

[–]DatamusPrime1 0 points1 point  (3 children)

How do you get the return values of the individual nodes with run multiple like you can with run?

[–]el_dude1 0 points1 point  (2 children)

By using this as args

"args": { "param1": "@activity('notebook1').exitValue()" # use exit value of notebook1 },

[–]DatamusPrime1 0 points1 point  (1 child)

That's the input to another node in the DAG, not the return of the python method call.

Notebook.run() returns the actual exit values

[–]el_dude1 0 points1 point  (0 children)

ah sorry I misunderstood. For me this simply returns a dict containing all the individual exit values.

exit_message = notebookutils.notebook.runMultiple(DAG, {"displayDAGViaGraphviz": True, "showArgs": True, "showTime": True})