run

abstractmethod PipelineStep.run(state)

Executes the logic of the pipeline step.

This method processes the given pipeline state. Implementations can either modify the state object in-place or create and return a new PipelineState instance.

To maintain a flexible and explicit API, this method must always return a PipelineState object. The calling code will use the returned value as the new state.

Parameters:

state (PipelineState) – The current state of the pipeline to be processed. Note that this object can be mutated by the method.

Returns:

The updated state of the pipeline. This can be the mutated input state object or a completely new instance.

Return type:

PipelineState