Add weekly scheduler: scheduler.py

scheduler.py

@@ -0,0 +1,56 @@
+#!/usr/bin/env python3
+"""
+scheduler.py
+------------
+Runs as a background process alongside Streamlit.
+Triggers the full data pipeline every Monday at 9:00 AM US Central time.
+"""
+
+import logging
+import os
+import subprocess
+import sys
+from datetime import datetime
+
+from apscheduler.schedulers.blocking import BlockingScheduler
+from apscheduler.triggers.cron import CronTrigger
+from dotenv import load_dotenv
+
+load_dotenv()
+
+logging.basicConfig(
+    level=logging.INFO,
+    format="%(asctime)s [SCHEDULER] %(message)s",
+    handlers=[logging.StreamHandler()],
+)
+logger = logging.getLogger(__name__)
+
+
+def run_pipeline():
+    logger.info(f"Weekly pipeline triggered at {datetime.now().isoformat()}")
+    env = os.environ.copy()
+    try:
+        subprocess.run(
+            [
+                sys.executable, "update_data.py",
+                "--pull", "--overwrite-pdf", "--continue-on-error",
+            ],
+            env=env,
+            check=False,
+        )
+        logger.info("Weekly pipeline completed.")
+    except Exception as e:
+        logger.error(f"Weekly pipeline failed: {e}")
+
+
+if __name__ == "__main__":
+    scheduler = BlockingScheduler(timezone="America/Chicago")
+    scheduler.add_job(
+        run_pipeline,
+        CronTrigger(day_of_week="mon", hour=9, minute=0, timezone="America/Chicago"),
+    )
+    logger.info("Scheduler started — pipeline will run every Monday at 9:00 AM CT.")
+    try:
+        scheduler.start()
+    except (KeyboardInterrupt, SystemExit):
+        logger.info("Scheduler stopped.")