spb/wp8_uqo

1"""Orchestrator for the complete data acquisition pipeline."""23from __future__ import annotations45import asyncio67from src.utils import ensure_dirs, setup_logging8from src.api.polymarket import fetch_all_data as fetch_polymarket9from src.api.fred import fetch_all_fred_data10from src.api.yahoo import fetch_all_yahoo_data111213def run_all() -> None:14    """Run complete data acquisition pipeline."""15    ensure_dirs()16    logger = setup_logging("data_acquisition")17    logger.info("Starting data acquisition pipeline")1819    # Polymarket (async)20    logger.info("--- Phase 1/3: Polymarket ---")21    asyncio.run(fetch_polymarket())2223    # FRED24    logger.info("--- Phase 2/3: FRED ---")25    fetch_all_fred_data()2627    # Yahoo Finance28    logger.info("--- Phase 3/3: Yahoo Finance ---")29    fetch_all_yahoo_data()3031    logger.info("Data acquisition complete")323334if __name__ == "__main__":35    run_all()36