kde_cpi.data.pipeline module¶ High level orchestration helpers for CPI ingestion. async kde_cpi.data.pipeline.load_full_history(dsn, *, schema='public', truncate=True, data_files=None)[source]¶ Load the full CPI history and write it into the database. Return type: Dataset Parameters: dsn (str) schema (str) truncate (bool) data_files (Sequence[str] | None) async kde_cpi.data.pipeline.update_current_periods(dsn, *, schema='public')[source]¶ Refresh the current-year CPI data without truncating history. Return type: Dataset Parameters: dsn (str) schema (str)