Upload 6 files

app.py

@@ -221,7 +221,7 @@ def register_custom_routes(fastapi_app: FastAPI) -> None:
         return JSONResponse(
             {
                 "name": "Agentic Space Factory",
-                "version": "v69-unified-progress-state",
+                "version": "v70-progress-resume-events-latency",
                 "bucket_default": settings.bucket_name,
                 "workflows": ["build_from_model_card", "validate_existing_space", "runs_explorer"],
                 "custom_ui_status": "root_custom_ui",
@@ -395,12 +395,13 @@ def register_custom_routes(fastapi_app: FastAPI) -> None:
         bucket_source = user_bucket_source(username=ctx["username"], bucket_name=bucket_name)
         runs = list_recent_runs(bucket_source=bucket_source, token=ctx["token"], limit=limit)
         resumable = find_latest_resumable_run(runs)
-        if not resumable:
-            return JSONResponse({"run": None, "view": None, "bucket_source": bucket_source, "reason": "no_resumable_run"})
-        run_id = validate_run_id(str(resumable.get("run_id")))
+        selected = resumable or (runs[0] if runs else None)
+        if not selected:
+            return JSONResponse({"run": None, "view": None, "bucket_source": bucket_source, "reason": "no_run"})
+        run_id = validate_run_id(str(selected.get("run_id")))
         bundle = read_run_bundle(run_id, bucket_source=bucket_source, token=ctx["token"], include_heavy=False)
         view = build_run_view_model(run_id, bundle, bucket_source=bucket_source)
-        return JSONResponse({"run": resumable, "view": view, "bucket_source": bucket_source, "reason": "latest_resumable_run"})
+        return JSONResponse({"run": selected, "view": view, "bucket_source": bucket_source, "reason": "latest_resumable_run" if resumable else "latest_run"})
 
     @fastapi_app.get("/api/runs/{run_id}")
     async def api_run_detail(request: Request, run_id: str, bucket_name: str = settings.bucket_name):  # type: ignore[no-untyped-def]
@@ -519,10 +520,14 @@ def register_custom_routes(fastapi_app: FastAPI) -> None:
         if job_stage and not job_info.get("error"):
             effective_state["job_stage"] = job_stage
             # Use Job stage as live source of truth while the bucket lags.
-            if job_stage in {"running", "failed", "cancelled"}:
+            if job_stage in {"running", "cancelled"}:
                 effective_state["status"] = job_stage
             elif job_stage == "success" and not (bundle.get("events") or []):
                 effective_state["status"] = "success"
+            # A failed HF Job stage is not always the final product state:
+            # some runs can still be in validation/repair/manual phases based on
+            # bucket events. Keep job_stage as metadata and let progress_from_events
+            # decide if the furthest observed step is truly failed.
         events = _merge_events(bundle.get("events") or [], job_log_events)
         progress = progress_from_events(events, state=effective_state)
         view_bundle = {**bundle, "events": events}