kedro.framework.hooks.specs.NodeSpecs

class kedro.framework.hooks.specs.NodeSpecs

Bases: object

Namespace that defines all specifications for a node’s lifecycle hooks.

Attributes

Methods

NodeSpecs.after_node_run(node, catalog, …)	Hook to be invoked after a node runs.
NodeSpecs.before_node_run(node, catalog, …)	Hook to be invoked before a node runs.
NodeSpecs.on_node_error(error, node, …)	Hook to be invoked if a node run throws an uncaught error.

__init__()

Initialize self. See help(type(self)) for accurate signature.

after_node_run(node, catalog, inputs, outputs, is_async, run_id)

Hook to be invoked after a node runs. The arguments received are the same as those used by kedro.runner.run_node as well as the outputs of the node run.

Parameters

• node (Node) – The Node that ran.

• catalog (DataCatalog) – A DataCatalog containing the node’s inputs and outputs.

• inputs (Dict[str, Any]) – The dictionary of inputs dataset. The keys are dataset names and the values are the actual loaded input data, not the dataset instance.

• outputs (Dict[str, Any]) – The dictionary of outputs dataset. The keys are dataset names and the values are the actual computed output data, not the dataset instance.

• is_async (bool) – Whether the node was run in async mode.

• run_id (str) – The id of the run.

Return type

None

before_node_run(node, catalog, inputs, is_async, run_id)

Hook to be invoked before a node runs. The arguments received are the same as those used by kedro.runner.run_node

Parameters

• node (Node) – The Node to run.

• catalog (DataCatalog) – A DataCatalog containing the node’s inputs and outputs.

• inputs (Dict[str, Any]) – The dictionary of inputs dataset. The keys are dataset names and the values are the actual loaded input data, not the dataset instance.

• is_async (bool) – Whether the node was run in async mode.

• run_id (str) – The id of the run.

Return type

Optional[Dict[str, Any]]

Returns

Either None or a dictionary mapping dataset name(s) to new value(s).

If returned, this dictionary will be used to update the node inputs, which allows to overwrite the node inputs.

on_node_error(error, node, catalog, inputs, is_async, run_id)

Hook to be invoked if a node run throws an uncaught error. The signature of this error hook should match the signature of before_node_run along with the error that was raised.

Parameters

• error (Exception) – The uncaught exception thrown during the node run.

• node (Node) – The Node to run.

• catalog (DataCatalog) – A DataCatalog containing the node’s inputs and outputs.

• inputs (Dict[str, Any]) – The dictionary of inputs dataset. The keys are dataset names and the values are the actual loaded input data, not the dataset instance.

• is_async (bool) – Whether the node was run in async mode.

• run_id (str) – The id of the run.