Upload 4 files

README.md

@@ -133,7 +133,7 @@ See `CHANGELOG_V194.md` for the Model Pre-scan Decision Card UI pass.
 See `CHANGELOG_V195.md` for the Runtime CSS Cleanup with Legacy Safety Net pass.
 
 
-Current release: Agentic Space Factory v198.26.94.
+Current release: Agentic Space Factory v198.26.98.
 
 ## v198.26.87 — Runs Explorer Badge Rail Alignment
 

app.py

@@ -1043,9 +1043,12 @@ def register_custom_routes(fastapi_app: FastAPI) -> None:
             space_test_policy = parent_view.get("space_test_policy") or parent_view.get("space_test", {}).get("policy") or {}
             if not space_test_policy.get("enabled"):
                 raise ValueError(str(space_test_policy.get("message") or "This Build Run is not eligible for linked Space Test yet."))
-            api_name_for_validation = payload.get("api_name")
+            payload_source_raw = str(payload.get("payload_source") or "").strip()
+            manual_endpoint_override = bool(payload.get("endpoint_override")) or payload_source_raw == "endpoint_registry_manual_override"
+            api_name_for_validation = str(payload.get("api_name") or "").strip()
             replay_source: dict[str, Any] = {}
-            if str(space_test_policy.get("mode") or payload.get("validation_mode") or "").strip().lower() == "replay":
+            replay_mode_requested = str(space_test_policy.get("mode") or payload.get("validation_mode") or "").strip().lower() == "replay"
+            if replay_mode_requested:
                 replay_source = _linked_replay_source_from_parent_bundle(
                     parent_build_run_id,
                     parent_bundle,
@@ -1053,13 +1056,16 @@ def register_custom_routes(fastapi_app: FastAPI) -> None:
                     str(payload.get("expected_output_type") or "any"),
                 )
                 if replay_source:
-                    api_name_for_validation = replay_source.get("api_name") or api_name_for_validation
+                    if not manual_endpoint_override:
+                        api_name_for_validation = replay_source.get("api_name") or api_name_for_validation
                     test_args = replay_source.get("test_args") if isinstance(replay_source.get("test_args"), list) else test_args
                     test_kwargs = replay_source.get("test_kwargs") if isinstance(replay_source.get("test_kwargs"), dict) else test_kwargs
                 else:
                     raise ValueError("Replay validation requires a successful parent automatic smoke payload. Select a Build Run with a completed smoke test, or use Complete/Recover validation instead of Replay.")
-            if space_test_policy.get("requires_endpoint_discovery") and str(api_name_for_validation or "").strip() in {"", "/generate"} and not replay_source:
+            if space_test_policy.get("requires_endpoint_discovery") and str(api_name_for_validation or "").strip() in {"", "/generate"} and not replay_source and not manual_endpoint_override:
                 api_name_for_validation = ""
+            requested_validation_mode = space_test_policy.get("mode") or payload.get("validation_mode") or "complete"
+            validation_mode_for_launch = "complete" if manual_endpoint_override and str(requested_validation_mode or "").strip().lower() == "replay" else requested_validation_mode
             # Compatibility anchor: "ui_payload_source": payload.get("payload_source") or ""
             validation_launch_payload = {
                 "schema_version": "1.0",
@@ -1070,12 +1076,15 @@ def register_custom_routes(fastapi_app: FastAPI) -> None:
                 "expected_output_type": payload.get("expected_output_type") or replay_source.get("expected_output_type") or "any",
                 "test_args": test_args,
                 "test_kwargs": test_kwargs,
-                "validation_mode": space_test_policy.get("mode") or payload.get("validation_mode") or "complete",
-                "payload_source": "parent_automatic_smoke" if replay_source else (payload.get("payload_source") or "ui_payload"),
+                "validation_mode": validation_mode_for_launch,
+                "payload_source": (payload.get("payload_source") if manual_endpoint_override else "parent_automatic_smoke") if replay_source else (payload.get("payload_source") or "ui_payload"),
+                "endpoint_override": bool(manual_endpoint_override),
+                "endpoint_registry_source_run_id": payload.get("endpoint_registry_source_run_id") or "",
                 "replay_source_present": bool(replay_source),
-                "ui_payload_source": "parent_automatic_smoke" if replay_source else (payload.get("payload_source") or ""),
+                "ui_payload_source": (payload.get("payload_source") if manual_endpoint_override else "parent_automatic_smoke") if replay_source else (payload.get("payload_source") or ""),
                 "space_test_policy": {
                     "mode": space_test_policy.get("mode"),
+                    "launch_mode": validation_mode_for_launch,
                     "requires_endpoint_discovery": bool(space_test_policy.get("requires_endpoint_discovery")),
                     "effective_status_on_success": space_test_policy.get("effective_status_on_success"),
                 },
@@ -1092,7 +1101,7 @@ def register_custom_routes(fastapi_app: FastAPI) -> None:
                 live_timeout_seconds=payload.get("live_timeout_seconds") or 1800,
                 validation_mode=validation_launch_payload["validation_mode"],  # effectively: validation_mode=space_test_policy.get("mode")
                 effective_status_on_success=space_test_policy.get("effective_status_on_success") or "validated_after_manual_space_test",
-                parent_replay_source_json=json.dumps(replay_source, ensure_ascii=False) if replay_source else None,
+                parent_replay_source_json=json.dumps(replay_source, ensure_ascii=False) if replay_source and not manual_endpoint_override else None,
                 validation_launch_payload_json=json.dumps(validation_launch_payload, ensure_ascii=False),
                 run_id=payload.get("run_id"),
                 bucket_name=bucket_name,
@@ -1392,6 +1401,11 @@ def register_custom_routes(fastapi_app: FastAPI) -> None:
                 "final_status_reconciliation": bundle.get("final_status_reconciliation") or {},
                 "eval_record": bundle.get("eval_record") or {},
                 "api_schema": bundle.get("api_schema") or {},
+                "space_test_endpoint_registry": bundle.get("space_test_endpoint_registry") or {},
+                "gradio_endpoint_discovery": bundle.get("gradio_endpoint_discovery") or {},
+                "gradio_schema": bundle.get("gradio_schema") or {},
+                "endpoint_candidates": bundle.get("endpoint_candidates") or {},
+                "selected_endpoint": bundle.get("selected_endpoint") or {},
                 "validation_payload": bundle.get("validation_payload") or {},
                 "validation_failure_diagnosis": bundle.get("validation_failure_diagnosis") or {},
                 "payload_source": bundle.get("payload_source") or {},