kedro.pipeline

Description

kedro.pipeline provides functionality to define and execute data-driven pipelines.

Classes

kedro.pipeline.Pipeline(nodes, *[, name])	A Pipeline defined as a collection of Node objects.
kedro.pipeline.node.Node(func, inputs, …)	Node is an auxiliary class facilitating the operations required to run user-provided functions as part of Kedro pipelines.

Functions

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

Create a node in the pipeline by providing a function to be called along with variable names for inputs and/or outputs.

Decorators

kedro.pipeline.decorators.log_time(func)	A function decorator which logs the time taken for executing a function.
kedro.pipeline.decorators.mem_profile(func)	A function decorator which profiles the memory used when executing the function.