Add daily auto-scan: runs on startup if stale, then every 24h

app.py

@@ -9,7 +9,8 @@ from __future__ import annotations
 import os
 import sys
 import threading
-from datetime import datetime
+import time
+from datetime import datetime, timedelta
 from typing import Optional
 
 import numpy as np
@@ -77,9 +78,21 @@ RESULTS_STATE: dict = {
     "last_run": None,
     "last_msg": "No scan run yet.",
     "scanned_universe": [],
+    "next_daily_run": None,  # datetime of the next scheduled auto-scan
 }
 
 
+# Daily auto-scan configuration
+DAILY_SCAN_INITIAL_DELAY_SEC = 20        # let the app + Gradio queue boot
+DAILY_SCAN_PERIOD_SEC = 24 * 3600        # 24 hours between scheduled scans
+
+
+class _NoOpProgress:
+    """No-op stand-in for ``gr.Progress()`` used by background scans."""
+    def __call__(self, frac, desc=None):
+        pass
+
+
 # ---------------------------------------------------------------------------
 # Helpers
 # ---------------------------------------------------------------------------
@@ -87,7 +100,11 @@ RESULTS_STATE: dict = {
 def _format_status() -> str:
     n = 0 if RESULTS_STATE["df"] is None else len(RESULTS_STATE["df"])
     last = RESULTS_STATE["last_run"].strftime("%Y-%m-%d %H:%M:%S") if RESULTS_STATE["last_run"] else "never"
-    return f"**Last run:** {last}  •  {n} stocks  •  {RESULTS_STATE['last_msg']}"
+    nxt = RESULTS_STATE.get("next_daily_run")
+    nxt_str = ""
+    if nxt is not None:
+        nxt_str = f"  •  **Next auto-scan:** {nxt.strftime('%Y-%m-%d %H:%M:%S')} UTC"
+    return f"**Last run:** {last}  •  {n} stocks  •  {RESULTS_STATE['last_msg']}{nxt_str}"
 
 
 def _result_columns() -> list[str]:
@@ -305,6 +322,76 @@ def _start_auto_improve(base_weights: dict) -> None:
     threading.Thread(target=_worker, daemon=True).start()
 
 
+# ---------------------------------------------------------------------------
+# Daily auto-scan
+# ---------------------------------------------------------------------------
+
+def _run_scheduled_scan(reason: str) -> None:
+    """Run a single full-universe-Filtered scan with the slider defaults
+    and update :data:`RESULTS_STATE`.  Used by :func:`_start_daily_scan`.
+    """
+    weights, _ = _resolve_weights(
+        False,
+        DEFAULT_WEIGHTS["cmf"],
+        DEFAULT_WEIGHTS["obv_slope"],
+        DEFAULT_WEIGHTS["big_bar_ratio"],
+        DEFAULT_WEIGHTS["vwap_dev"],
+        DEFAULT_WEIGHTS["rvol_signed"],
+    )
+    try:
+        df, frames, scanned, msg = _do_scan(
+            "Filtered (default)", 5.0, 5_000_000.0, "All", "All",
+            weights, _NoOpProgress(),
+        )
+    except Exception as e:
+        RESULTS_STATE["last_msg"] = f"Error ({reason}): {e}"
+        return
+
+    suffix = f" (auto: {reason})"
+    RESULTS_STATE["df"] = df
+    RESULTS_STATE["frames"] = frames
+    RESULTS_STATE["weights"] = weights
+    RESULTS_STATE["last_run"] = datetime.utcnow()
+    RESULTS_STATE["last_msg"] = f"{msg}{suffix}"
+    RESULTS_STATE["scanned_universe"] = scanned
+    if df is not None and not df.empty:
+        _start_auto_improve(weights)
+
+
+def _start_daily_scan() -> None:
+    """Background thread: run a scan on startup (if the last one is
+    older than :data:`DAILY_SCAN_PERIOD_SEC`), then re-run once every
+    24 hours.  HF Spaces can sleep after 48h of inactivity, so the
+    startup gate is what actually delivers the "one scan per day"
+    guarantee: a fresh visit always triggers a scan if the cached one
+    is stale.
+    """
+    def _worker():
+        time.sleep(DAILY_SCAN_INITIAL_DELAY_SEC)
+        # Initial scan: only if last successful scan is stale
+        last = RESULTS_STATE.get("last_run")
+        stale = (
+            last is None
+            or (datetime.utcnow() - last).total_seconds() > DAILY_SCAN_PERIOD_SEC
+        )
+        if stale:
+            try:
+                _run_scheduled_scan("startup")
+            except Exception as e:
+                RESULTS_STATE["last_msg"] = f"Auto-scan (startup) failed: {e}"
+        # Then loop, scheduling a scan every 24h
+        while True:
+            RESULTS_STATE["next_daily_run"] = (
+                datetime.utcnow() + timedelta(seconds=DAILY_SCAN_PERIOD_SEC)
+            )
+            time.sleep(DAILY_SCAN_PERIOD_SEC)
+            try:
+                _run_scheduled_scan("daily")
+            except Exception as e:
+                RESULTS_STATE["last_msg"] = f"Auto-scan (daily) failed: {e}"
+    threading.Thread(target=_worker, daemon=True).start()
+
+
 # ---------------------------------------------------------------------------
 # Scan logic
 # ---------------------------------------------------------------------------
@@ -771,6 +858,10 @@ def build_ui() -> gr.Blocks:
 demo = build_ui()
 
 
+# Kick off the once-per-day auto-scan thread
+_start_daily_scan()
+
+
 if __name__ == "__main__":
     demo.queue(max_size=8).launch(
         server_name="0.0.0.0",