----------------------------------------------------------------------
This is the API documentation for the gdtest_skill_rich library.
----------------------------------------------------------------------


## Classes

Core classes


Pipeline(name: str = 'default', schema: str = 'v2')

An ordered chain of processing stages.

Parameters
----------
name
    Pipeline identifier.
schema
    Schema version string for reproducibility.

Stage(name: str, fn=None)

A single processing step in a pipeline.

Parameters
----------
name
    Stage identifier.
fn
    Callable that processes data.

Source(uri: str, format: str = 'json')

A data source feeding a pipeline.

Parameters
----------
uri
    Connection URI (file path, URL, or database DSN).
format
    Data format (csv, json, parquet).

Sink(uri: str, format: str = 'json')

A data destination for pipeline output.

Parameters
----------
uri
    Destination URI.
format
    Output format.


## Functions

Public functions


run_pipeline(source: gdtest_skill_rich.Source, *stages: gdtest_skill_rich.Stage, sink: gdtest_skill_rich.Sink) -> dict

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

Parameters
----------
source
    Data source.
*stages
    Processing stages.
sink
    Data destination.

Returns
-------
dict
    Execution summary.

validate_schema(data: dict, schema: str = 'v2') -> bool

Validate data against a schema version.

Parameters
----------
data
    Data to validate.
schema
    Schema version string.

Returns
-------
bool
    True if valid.