ETL API

Entrypoints and Runtime Contracts

loom.etl.runner

Runner API for compiling and executing ETL pipelines.

loom.etl.runtime

Runtime contracts used by executor and backend implementations.

Declarative Authoring

loom.etl.declarative

I/O declaration API for ETL sources, targets, and file formats.

loom.etl.pipeline

User-facing alias for ETL pipeline declaration primitives.

loom.etl.schema

Schema, contracts, and table-reference primitives for ETL.

Execution Infrastructure

loom.etl.storage

Storage config, location mapping, and routing.

loom.etl.checkpoint

Checkpoint storage API for ETL pipeline intermediates.

loom.etl.lineage

ETL lineage observability helpers.

Backends

loom.etl.backends._historify

Backend-agnostic SCD Type 2 transform and HistorifyBackend Protocol.

loom.etl.backends.polars

Polars backend for the Loom ETL framework.

loom.etl.backends.spark

PySpark backend for the Loom ETL framework.

Testing

loom.etl.testing

ETL testing utilities — stubs, runners, scenario, and pytest fixtures.

loom.etl.testing.spark

Spark testing utilities and pytest fixtures for the Loom ETL framework.