Upload 14 files

src/timeline_model.py

@@ -443,14 +443,12 @@ def _archive_warning(bundle: dict[str, Any], *, terminal: bool) -> dict[str, Any
     status = _eval_publish(bundle)
     if not status or status.get("published") is True:
         return None
-    # record_not_ready is the expected state while a run is still executing.
-    # It should not become a global warning until the run has actually ended.
-    if not terminal and _is_record_not_ready(status):
+    # record_not_ready is expected during the terminal write/reconcile window.
+    # It is a neutral finalization state, not an action required for users.
+    if _is_record_not_ready(status):
         return None
     if status.get("attempted"):
         return {"code": "eval_archive_not_published", "label": "Eval archive not published", "detail": str(status.get("reason") or "Backend archive copy did not complete.")}
-    if terminal:
-        return {"code": "eval_archive_pending", "label": "Eval archive pending", "detail": "Backend archive copy has not been confirmed yet."}
     return None
 
 
@@ -513,7 +511,7 @@ def _build_phase_details(bundle: dict[str, Any], phase: str) -> list[dict[str, A
                     details.append({"label": str(eval_status.get("archive_relative_path")), "status": "info"})
             elif eval_status.get("attempted"):
                 if _is_record_not_ready(eval_status):
-                    details.append({"label": "Eval archive pending until the run completes", "status": "pending"})
+                    details.append({"label": "Eval archive finalizing", "status": "info"})
                 else:
                     details.append({"label": f"Eval archive not published: {eval_status.get('reason') or 'unknown'}", "status": "warning"})
             else:
@@ -542,9 +540,11 @@ def _build_phase_details(bundle: dict[str, Any], phase: str) -> list[dict[str, A
 
 def _phase_summary(bundle: dict[str, Any], phase: str, status: str) -> str:
     if phase == "agent":
-        warning = _pi_model_warning(bundle)
-        if warning:
-            return warning["label"]
+        # A Pi model mismatch is an audit note rendered in Run notes, not a
+        # phase-level issue. Keep the Agent phase focused on Pi execution and
+        # trace collection so successful terminal runs do not show a misleading
+        # NEEDS ATTENTION state.
+        pass
     if phase == "hardware":
         warning = _hardware_warning(bundle)
         if warning:
@@ -587,6 +587,8 @@ def _phase_summary(bundle: dict[str, Any], phase: str, status: str) -> str:
             return "Eval archive published"
         if eval_status.get("attempted") and not _is_record_not_ready(eval_status):
             return "Eval archive attempted"
+        if eval_status.get("attempted") and _is_record_not_ready(eval_status):
+            return "Finalizing archive" if status in {"pending", "running"} else "Final artifacts written"
         return "Archive pending" if status in {"pending", "running"} else "Final artifacts written"
     if phase == "done":
         label, _ = _status_label(_verdict(bundle))
@@ -632,6 +634,15 @@ def _phase_status(bundle: dict[str, Any], phase: str, verdict: str) -> str:
         pi_run = latest_by_step.get("pi_run") or {}
         if _lower(pi_run.get("status")) in RUNNING_STATUSES and not terminal:
             return "running"
+        if terminal:
+            material_events = [e for e in _events_for_phase(bundle, phase) if _lower(e.get("step")) != "pi_model_resolution"]
+            material_statuses = {_lower(e.get("status")) for e in material_events}
+            if material_statuses.intersection(FAILED_STATUSES):
+                return "failed"
+            if material_statuses.intersection(RUNNING_STATUSES):
+                return "running"
+            if material_statuses.intersection(SUCCESS_STATUSES) or _has_downstream_proof(bundle, phase):
+                return "complete"
 
     if phase == "deploy":
         blocker = _final_blocker_label(bundle)
@@ -654,18 +665,17 @@ def _phase_status(bundle: dict[str, Any], phase: str, verdict: str) -> str:
         if eval_status.get("published") is True:
             return "complete"
         if eval_status.get("attempted"):
-            if not terminal and _is_record_not_ready(eval_status):
-                return "pending"
+            if _is_record_not_ready(eval_status):
+                return "pending" if not terminal else "complete"
             return "warning"
         if terminal:
-            return "warning" if bundle.get("eval_record") else "pending"
+            return "complete" if bundle.get("eval_record") else "pending"
         return "pending"
 
     if phase == "deploy" and _build_error_observation(bundle):
         return "failed"
 
-    if phase == "agent" and _pi_model_warning(bundle):
-        return "warning"
+    # Pi model changes are surfaced as run notes, not phase warnings.
     if phase == "hardware" and _hardware_warning(bundle):
         return "warning"