Upload 2 files

app.py

@@ -26,9 +26,14 @@ import geo
 import globe as globe_mod
 import liquid
 import sidebar as sidebar_mod
+import trace_sync
 import transit_agent
 import transit_map
 
+# Mirror ./traces/ to a HF dataset repo (no-op without HF_TOKEN); the container
+# disk on Spaces is ephemeral, so this is what makes traces survive restarts.
+print(f"[flightdeck] {trace_sync.start()}")
+
 # ---- Preset regions (north, south, west, east) -----------------------------
 REGIONS = {
     "Europe":            (60.0, 36.0, -11.0, 30.0),
@@ -44,15 +49,6 @@ REGIONS = {
 MAX_FLIGHTS = 220  # keep the globe/LLM responsive
 
 
-def ensure_trace_directory():
-    """Creates the traces directory at runtime to ensure the agent can save output."""
-    base_dir = os.path.dirname(os.path.abspath(__file__))
-    trace_dir = os.path.join(base_dir, "traces")
-    os.makedirs(trace_dir, exist_ok=True)
-    return trace_dir
-
-ensure_trace_directory()
-
 def normalize_flight(raw: dict) -> dict | None:
     """Map an FR24 record to the fields the rest of the app expects."""
     lat = raw.get("lat")

trace_sync.py

@@ -0,0 +1,47 @@
+"""Persist agent traces to a Hugging Face dataset repo.
+
+On Spaces the container filesystem is ephemeral: traces written to ./traces/
+survive only until the Space restarts, and never show up in the repo Files tab.
+This module starts a `CommitScheduler` that periodically commits new/changed
+files from ./traces/ to a dataset repo, so every agent run stays auditable.
+
+Requires an HF_TOKEN (write) — set it as a Space secret. Without a token this
+is a silent no-op so local runs keep working unchanged. Override the target
+repo with TRACES_REPO (default: <your-username>/flightdeck-traces).
+"""
+from __future__ import annotations
+
+import os
+
+from agent import TRACES_DIR
+
+# Keep a module-level reference so the scheduler thread isn't garbage-collected.
+_SCHEDULER = None
+
+
+def start() -> str:
+    """Start the background sync. Returns a one-line status for logging."""
+    global _SCHEDULER
+    if _SCHEDULER is not None:
+        return "trace sync already running"
+    token = os.environ.get("HF_TOKEN") or os.environ.get("HUGGINGFACE_TOKEN")
+    if not token:
+        return "trace sync off — set HF_TOKEN (write) to push traces to a dataset repo"
+    try:
+        from huggingface_hub import CommitScheduler, whoami
+
+        repo_id = os.environ.get("TRACES_REPO")
+        if not repo_id:
+            user = whoami(token=token)["name"]
+            repo_id = f"{user}/flightdeck-traces"
+        _SCHEDULER = CommitScheduler(
+            repo_id=repo_id,
+            repo_type="dataset",
+            folder_path=TRACES_DIR,
+            path_in_repo="traces",
+            every=2,  # minutes
+            token=token,
+        )
+        return f"trace sync on → https://huggingface.co/datasets/{repo_id} (every 2 min)"
+    except Exception as e:  # noqa: BLE001 — tracing must never take the app down
+        return f"trace sync failed ({type(e).__name__}: {e}) — app continues without it"