File size: 732 Bytes
700e896 28c12aa 700e896 28c12aa 700e896 28c12aa 700e896 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 | """Preprocess phase — load → validate → enrich → materialize → expand.
Shipped: load + validate. The phase is orchestrated by ``pipeline.run_preprocess`` over a list of small
frame→frame ``Stage``s (``pipeline.preprocess_stages``) so each sub-stage is independently debuggable.
"""
from .load import load_candidates, to_date
from .materialize import materialize
from .pipeline import DATASET_AS_OF, Stage, preprocess_stages, run_preprocess
from .quality import quality
from .validate import FLAG_COLUMNS, validate
__all__ = [
"DATASET_AS_OF",
"FLAG_COLUMNS",
"Stage",
"load_candidates",
"materialize",
"preprocess_stages",
"quality",
"run_preprocess",
"to_date",
"validate",
]
|