GraphRunner is responsible for running a
hooks: Optional[List[GraphNodeHook]] = None) -> GraphRunner
Creates a new instance of a
graph_schema- The graph schema that will be instantiated and run.
model_storage- Storage which graph components can use to persist and load themselves.
execution_context- Context that will be passed to every
hooks- These are called before and after the execution of each node.
def run(inputs: Optional[Dict[Text, Any]] = None,
targets: Optional[List[Text]] = None) -> Dict[Text, Any]
Runs the instantiated graph with the given inputs and targets.
inputs- Input nodes to be added to the graph. These can be referenced by name in the "needs" key of a node in the schema.
targets- Nodes whose output is needed and must always run.
Returns- A mapping of target node name to output value.