| """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", | |
| ] | |