Fix kaggle status parse + add /admin/repoll for stuck rows

Bug: kaggle CLI prints status as "SubmissionStatus.COMPLETE" (an enum repr),
not "complete". The poller's `.lower() == 'complete'` check never matched,
so every kaggle submission timed out at 1800s with "polled without complete"
even when Kaggle had already scored it.

Fix: split on the last `.` and lowercase the suffix.

/admin/repoll/<run_id>: re-trigger the poll for a row whose poller bailed
out, without re-submitting (and burning Kaggle quota).

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>

server/api.py

@@ -191,7 +191,10 @@ def _kaggle_poll_loop(competition: str, description: str, run_id: str,
         for row in csv.DictReader(io.StringIO(ls.stdout)):
             if row.get("description") != description:
                 continue
-            status = (row.get("status") or "").lower()
+            # Kaggle prints status as "SubmissionStatus.COMPLETE" (enum repr),
+            # not just "complete" — match the suffix after the last dot.
+            status_raw = (row.get("status") or "")
+            status = status_raw.rsplit(".", 1)[-1].lower()
             if status == "complete":
                 pub = row.get("publicScore") or ""
                 priv = row.get("privateScore") or ""
@@ -472,6 +475,39 @@ def admin_delete():
     })
 
 
+@app.post("/admin/repoll/<run_id>")
+def admin_repoll(run_id: str):
+    """Re-trigger the Kaggle poll loop for a stuck/failed pending row, without
+    re-submitting to Kaggle. Useful after fixing a poller bug — the existing
+    Kaggle submission still has its score, we just need to read it.
+    """
+    sent_key = request.headers.get("X-Bypass-Key", "").strip()
+    if not (BYPASS_KEY and sent_key
+            and __import__("hmac").compare_digest(sent_key, BYPASS_KEY)):
+        return jsonify({"error": "bypass key required"}), 403
+    conn = _db()
+    row = conn.execute(
+        "SELECT task FROM submissions WHERE run_id = ?", (run_id,)
+    ).fetchone()
+    conn.close()
+    if not row:
+        return jsonify({"error": f"no run '{run_id}'"}), 404
+    task = row[0]
+    cfg = _manifest().get(task, {})
+    comp = cfg.get("backend_config", {}).get("competition")
+    if not comp:
+        return jsonify({"error": f"task '{task}' is not a kaggle backend"}), 400
+    description = f"graphtestbed-{run_id}"
+    import threading
+    threading.Thread(
+        target=_kaggle_poll_loop,
+        args=(comp, description, run_id),
+        daemon=True,
+    ).start()
+    return jsonify({"run_id": run_id, "task": task, "competition": comp,
+                    "status": "repolling"})
+
+
 @app.get("/run/<run_id>")
 def run_status(run_id: str):
     """Look up a submission by run_id. Useful for kaggle-backend submissions