gunz_cm.pipeline package

Subpackages

Submodules

gunz_cm.pipeline.core module

Core module for data-oriented pipeline construction and execution.

Examples

class gunz_cm.pipeline.core.Pipeline(steps: list[tuple[str, Callable[[Any], Any]]])[source]

Bases: object

A simple data-oriented pipeline that chains callable steps.

Examples

run(initial_data: Any = None) Any[source]

Executes the pipeline sequentially.

initial_dataAny, optional

The initial data to pass into the first pipeline step. Defaults to None.

Any

The output data from the final pipeline step.

Examples

gunz_cm.pipeline.core.create_pipeline(config: list[dict[str, Any]]) Pipeline[source]

Factory function to create a Pipeline from a configuration structure.

configlist[dict[str, Any]]

A list of configuration dictionaries, each specifying a pipeline step. Expected keys are ‘name’ (str), ‘target’ (str), and optionally ‘kwargs’ (dict).

Pipeline

The constructed pipeline.

ValueError

If a step is missing a ‘target’ key.

Examples

Module contents

class gunz_cm.pipeline.Pipeline(steps: list[tuple[str, Callable[[Any], Any]]])[source]

Bases: object

A simple data-oriented pipeline that chains callable steps.

Examples

run(initial_data: Any = None) Any[source]

Executes the pipeline sequentially.

initial_dataAny, optional

The initial data to pass into the first pipeline step. Defaults to None.

Any

The output data from the final pipeline step.

Examples

gunz_cm.pipeline.create_pipeline(config: list[dict[str, Any]]) Pipeline[source]

Factory function to create a Pipeline from a configuration structure.

configlist[dict[str, Any]]

A list of configuration dictionaries, each specifying a pipeline step. Expected keys are ‘name’ (str), ‘target’ (str), and optionally ‘kwargs’ (dict).

Pipeline

The constructed pipeline.

ValueError

If a step is missing a ‘target’ key.

Examples