kedro.pipeline

描述

kedro.pipeline 提供了定义和执行数据驱动管道的功能。

函数

kedro.pipeline.node(func, inputs, outputs, *)

在流水线中创建一个节点,通过提供一个待调用的函数以及输入和/或输出的变量名称。

kedro.pipeline.pipeline(pipe, *[, inputs, ...])

从一组节点和/或Pipeline中创建Pipeline

kedro.pipeline.Pipeline(nodes, *[, inputs, ...])

一个Pipeline被定义为Node对象的集合。

kedro.pipeline.node.Node(func, inputs, ...)

Node 是一个辅助类,用于简化将用户提供的函数作为 Kedro 管道的一部分运行所需的操作。

模块

异常

kedro.pipeline.pipeline.ModularPipelineError

当模块化流水线未使用辅助工具适当适配和集成时引发此错误。