Pipeline

A multi-step data processing pipeline.

Usage

Pipeline()

Provides methods for loading, cleaning, transforming, validating, aggregating, and exporting data.

Parameters

name: str

The pipeline name.

verbose: bool = False

Whether to print progress messages.

Examples

>>> p = Pipeline("etl")
>>> p.load({"items": [1, 2, 3]})