kedro.pipeline.pipeline

kedro.pipeline.pipeline(pipe, *, inputs=None, outputs=None, parameters=None, tags=None, namespace=None)[source]

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

Parameters:

  • pipe (Iterable[Node | Pipeline] | Pipeline) – 构成Pipeline的节点集合。如果在节点列表中提供了pipeline，这些pipeline将被展开，它们的所有节点都将成为这个新pipeline的一部分。

  • inputs (str | set[str] | dict[str, str] | None) – 作为连接点暴露给上游其他管道的输入名称或输入名称集合。这是可选的；如果不提供，管道输入会自动从管道结构中推断得出。当提供str或set[str]时，列出的输入名称将保持与所提供管道中的命名一致。当提供dict[str, str]时，当前输入名称将被映射到新名称。必须仅引用管道的自由输入。

  • outputs (str | set[str] | dict[str, str] | None) – 作为连接点暴露给下游其他管道的名称或名称集合。这是可选的；如果不提供，管道输出会从管道结构中自动推断。当提供str或set[str]时，列出的输出名称将保持与所提供管道中的命名相同。当提供dict[str, str]时，当前输出名称将被映射到新名称。可以同时引用管道的自由输出，以及需要暴露的中间结果。

  • parameters (str | set[str] | dict[str, str] | None) – 用于命名空间的参数名称或集合。 当提供str或set[str]时，列出的参数名称将保持与所提供管道中的命名一致。 当提供dict[str, str]时，当前参数名称将被映射到新名称。 参数可以不带params:前缀指定。

  • tags (str | Iterable[str] | None) - 可选的一组标签，将应用于所有管道节点。

  • namespace (str | None) – 一个前缀，将添加到所有数据集名称前，除了那些明确使用inputs/outputs参数命名的数据集，以及参数引用(params:和parameters)。

Raises:

  • ModularPipelineError – 当输入、输出或参数被错误指定，或它们在原始管道上不存在时。

  • ValueError – 当底层管道节点的输入/输出不符合预期类型(str, dict, list或None)时抛出。

Return type:

Pipeline

Returns:

一个新的Pipeline对象。