kedro.runner.run_node

kedro.runner.run_node(node, catalog, hook_manager, is_async=False, session_id=None)[source]

Run a single Node with inputs from and outputs to the catalog.

Parameters:
  • node (Node) – The Node to run.

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

  • hook_manager (PluginManager) – The PluginManager to activate hooks.

  • is_async (bool) – If True, the node inputs and outputs are loaded and saved asynchronously with threads. Defaults to False.

  • session_id (str | None) – The session id of the pipeline run.

Raises:

ValueError – Raised if is_async is set to True for nodes wrapping generator functions.

Return type:

Node

Returns:

The node argument.