PipelineStep

class PipelineStep

Bases: ABC

Abstract base class for a single step in a processing pipeline.

This class defines the interface for an operation that can be executed as part of an iterative estimation process managed by a Pipeline.

Each step receives the current PipelineState, performs a specific operation (e.g., an E-step or M-step), and returns the updated state.

Variables:

available_next_steps (list[type[PipelineStep]]) – A list of step types that can legally follow this step in a pipeline.

Methods

run(state)

Executes the logic of the pipeline step.

Notes

Subclasses must implement the abstract property available_next_steps and the abstract method run().