Upload 6 files

CHANGELOG.md

@@ -210,3 +210,11 @@
 - Persisted `launch.json`, `summary.json`, and a minimal `state.json` immediately after a Job launch, so running Jobs appear in the Run Explorer before the worker writes final artifacts.
 - Progress polling now falls back to launch metadata when `state.json`/`events.jsonl` are not ready yet.
 - Job links are preserved or reconstructed from launch metadata for active and historical runs.
+
+## v43 — Canonical run view model + mockup-oriented dashboard
+
+- Added a canonical Run View Model that normalizes heterogeneous worker/bucket statuses into stable product states.
+- Added `/api/runs/resumable` and `/api/runs/{run_id}/view` endpoints for bucket-led recovery and UI rendering.
+- Enriched `/api/runs/{run_id}/progress` with the new `view` payload while preserving the previous progress contract.
+- Reworked the custom UI toward the product mockup: sidebar, run summary header, product pipeline stepper, agent activity feed, diagnostics panel, and Space Test preview.
+- Added explicit tests for running, manual hardware, success, stale, and resumable run selection states.

README.md

@@ -173,3 +173,8 @@ The Run Explorer reads launch metadata, summary metadata, state, gate files, and
 
 The live progress timeline is designed to avoid horizontal scrolling and uses explicit step states: completed, active, pending, and failed. Historical run Job links are reconstructed from `job_id` when possible, so the Job button should remain available even when older summaries did not store a full `job_url`.
 
+
+
+## v45 Simple Custom Dashboard
+
+This version keeps the working Agentic Space Factory workflows and presents them in a simpler custom interface: Build on the left, Runs & Progress on the right, plus a full Run Explorer and Space Test view.

app.py

@@ -20,6 +20,7 @@ from src.jobs import (
 )
 from src.runs import make_run_id, validate_run_id
 from src.progress import progress_from_events
+from src.view_models import build_run_view_model, find_latest_resumable_run
 from src.security import redact
 
 
@@ -149,7 +150,7 @@ def register_custom_routes(fastapi_app: FastAPI) -> None:
         return JSONResponse(
             {
                 "name": "Agentic Space Factory",
-                "version": "v42-tabbed-runs-recovery",
+                "version": "v45-simple-custom-dashboard",
                 "bucket_default": settings.bucket_name,
                 "workflows": ["build_from_model_card", "validate_existing_space", "runs_explorer"],
                 "custom_ui_status": "root_custom_ui",
@@ -317,13 +318,35 @@ def register_custom_routes(fastapi_app: FastAPI) -> None:
             }
         )
 
+    @fastapi_app.get("/api/runs/resumable")
+    async def api_resumable_run(request: Request, bucket_name: str = settings.bucket_name, limit: int = 100):  # type: ignore[no-untyped-def]
+        ctx = _oauth_context_from_request(request)
+        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")))
+        bundle = read_run_bundle(run_id, bucket_source=bucket_source, token=ctx["token"])
+        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"})
+
     @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]
         ctx = _oauth_context_from_request(request)
         run_id = validate_run_id(run_id)
         bucket_source = user_bucket_source(username=ctx["username"], bucket_name=bucket_name)
         bundle = read_run_bundle(run_id, bucket_source=bucket_source, token=ctx["token"])
-        return JSONResponse({"run_id": run_id, "bucket_source": bucket_source, **bundle})
+        view = build_run_view_model(run_id, bundle, bucket_source=bucket_source)
+        return JSONResponse({"run_id": run_id, "bucket_source": bucket_source, "view": view, **bundle})
+
+    @fastapi_app.get("/api/runs/{run_id}/view")
+    async def api_run_view(request: Request, run_id: str, bucket_name: str = settings.bucket_name):  # type: ignore[no-untyped-def]
+        ctx = _oauth_context_from_request(request)
+        run_id = validate_run_id(run_id)
+        bucket_source = user_bucket_source(username=ctx["username"], bucket_name=bucket_name)
+        bundle = read_run_bundle(run_id, bucket_source=bucket_source, token=ctx["token"])
+        return JSONResponse(build_run_view_model(run_id, bundle, bucket_source=bucket_source))
 
     @fastapi_app.get("/api/runs/{run_id}/progress")
     async def api_run_progress(request: Request, run_id: str, bucket_name: str = settings.bucket_name):  # type: ignore[no-untyped-def]
@@ -348,6 +371,7 @@ def register_custom_routes(fastapi_app: FastAPI) -> None:
                 "hardware_strategy": bundle.get("hardware_strategy") or {},
                 "technical_blockers": bundle.get("technical_blockers") or {},
                 "events": events[-20:],
+                "view": build_run_view_model(run_id, bundle, bucket_source=bucket_source),
                 "links": _api_links(
                     run_id=run_id,
                     bucket_source=bucket_source,