update

app.py

@@ -1,16 +1,15 @@
+import json
+import os
+import time
+
 import gradio as gr
 import pandas as pd
 from huggingface_hub import snapshot_download
 
 from src.display.css_html_js import custom_css
-from src.leaderboard.student_results import (
-    get_group_submission_history,
-    get_latest_submission,
-    get_student_leaderboard_df,
-)
-import time
+from src.leaderboard.student_results import get_group_submission_history, get_student_leaderboard_df
 from src.submission.student_queue import queue_student_submission
-from src.envs import EVAL_RESULTS_PATH, RESULTS_REPO, TOKEN
+from src.envs import EVAL_REQUESTS_PATH, EVAL_RESULTS_PATH, PROJ_DIR, QUEUE_REPO, RESULTS_REPO, TOKEN
 
 
 demo = gr.Blocks(css=custom_css)
@@ -48,6 +47,34 @@ with demo:
                     return obj.name
                 return str(obj)
 
+            def _load_latest_request(group_id: str, ts: str) -> dict | None:
+                """Load the latest request.json for this group and timestamp from the local request cache."""
+                base_dir = os.path.join(EVAL_REQUESTS_PATH, PROJ_DIR)
+                if not os.path.isdir(base_dir):
+                    return None
+
+                rows = []
+                for root, _, files in os.walk(base_dir):
+                    for fname in files:
+                        if not fname.endswith(".json"):
+                            continue
+                        try:
+                            with open(os.path.join(root, fname), "r") as f:
+                                data = json.load(f)
+                            if str(data.get("group_id", "")).strip() != str(group_id).strip():
+                                continue
+                            if data.get("timestamp") != ts:
+                                continue
+                            rows.append(data)
+                        except Exception:
+                            continue
+
+                if not rows:
+                    return None
+
+                rows.sort(key=lambda x: x.get("timestamp", ""), reverse=True)
+                return rows[0]
+
             def handle_student_submit(group_id, alias, state_dict_file, model_py_file, preproc_py_file, progress=gr.Progress()):
                 try:
                     msg, ts = queue_student_submission(
@@ -69,6 +96,7 @@ with demo:
                         return f"Timed out waiting for results. Please check back later. Submission ID: {ts}"
                     
                     try:
+                        # Keep both results and request queues up to date locally
                         snapshot_download(
                             repo_id=RESULTS_REPO,
                             local_dir=EVAL_RESULTS_PATH,
@@ -77,18 +105,24 @@ with demo:
                             etag_timeout=30,
                             token=TOKEN,
                         )
+                        snapshot_download(
+                            repo_id=QUEUE_REPO,
+                            local_dir=EVAL_REQUESTS_PATH,
+                            repo_type="dataset",
+                            tqdm_class=None,
+                            etag_timeout=30,
+                            token=TOKEN,
+                        )
                     except Exception:
-                        pass # Ignore network errors during polling
-                    
-                    submission = get_latest_submission(group_id)
+                        # Ignore transient network/cache errors and retry
+                        pass
+
+                    # Read status and possible error message from request.json
+                    submission = _load_latest_request(group_id, ts)
                     if not submission:
                         continue
-                        
-                    # Check if this is the submission we just made
-                    if submission.get("timestamp") != ts:
-                        continue
-                        
-                    status = submission.get("status", "UNKNOWN")
+
+                    status = submission.get("status", "PENDING")
                     if status == "PENDING":
                         progress(0.5, desc="Evaluating...")
                     elif status == "SUCCESS":
@@ -215,8 +249,6 @@ with demo:
                     history_rows.append(
                         {
                             "Timestamp": sub.get("timestamp", ""),
-                            "Status": sub.get("status", "UNKNOWN"),
-                            "Error": sub.get("error", ""),
                             "Dataset": sub.get("dataset", ""),
                             "Avg distance (m)": sub.get("avg_distance_m"),
                             "Avg infer (ms)": sub.get("avg_infer_ms"),