PipelineExecutionPlan

laktory.models.pipeline.PipelineExecutionPlan

Bases: BaseModel

A pipeline execution plan defines the pipeline tasks to be executed according to the selected nodes/tasks/tags and their dependencies. It constructs a DAG of pipeline tasks, where each task can consist of one or more nodes that share the same execution_task_name.

PARAMETER	DESCRIPTION
pipeline	Pipeline TYPE: Annotated[Pipeline, SkipValidation] | VariableType
selects	List of node names with optional dependency notation: {node_name}: Execute the node only. *{node_name}: Execute the node and its upstream dependencies. {node_name}*: Execute the node and its downstream dependencies. *{node_name}*: Execute the node, its upstream, and downstream dependencies. TYPE: list[str] | None | VariableType DEFAULT: None

ATTRIBUTE	DESCRIPTION
dag	Constructs a DAG for the execution plan, where each node is either: TYPE: DiGraph
node_names	Selected pipeline node names TYPE: list[str]
nodes_dag	Selected pipeline nodes DAG TYPE: DiGraph
nodes_dict	Selected pipeline nodes dict
tasks	List of pipeline tasks to be executed. Each task is either:
tasks_dict	Tasks dictionary

dag property

Constructs a DAG for the execution plan, where each node is either: - A single pipeline node (default execute_task_name), or - A group of nodes (if they share the same execute_task_name).

Pipeline nodes without sink(s) are omitted unless they are leaf (terminal) nodes as they will be executed implicitly when executing their downstream nodes.

RETURNS	DESCRIPTION
DiGraph	A directed acyclic graph representing the execution plan.

node_names property

Selected pipeline node names

nodes_dag property

Selected pipeline nodes DAG

nodes_dict property

Selected pipeline nodes dict

tasks property

List of pipeline tasks to be executed. Each task is either: - A single pipeline node (default execute_task_name), or - A group of nodes (if they share the same execute_task_name).

Pipeline nodes without sink(s) are omitted unless they are leaf (terminal) nodes as they will be executed implicitly when executing their downstream nodes.

RETURNS	DESCRIPTION
output	TYPE: list[PipelineTask]

tasks_dict property

Tasks dictionary