kedro.runner.run_node

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

使用来自catalog的输入和输出运行单个Node。

Parameters:

  • node (Node) – 要运行的Node。

  • catalog (CatalogProtocol) – 一个实现了CatalogProtocol的实例，包含节点的输入和输出。

  • hook_manager (PluginManager) – 用于激活钩子的PluginManager。

  • is_async (bool) – 如果为True，节点输入和输出将通过线程异步加载和保存。默认为False。

  • session_id (str | None) – 管道运行的会话ID。

Raises:

ValueError – 当为封装生成器函数的节点设置is_async为True时引发。

Return type:

节点

Returns:

节点参数。