run_pipeline()

One-shot helper: source -> stages -> sink.

Usage

Source

run_pipeline(
    source,
    *stages,
    sink,
)

Parameters

source: Source

Data source.

*stages: Stage

Processing stages.

sink: Sink

Data destination.

Returns

dict

Execution summary.