Upload 15 files

src/version.py

@@ -1,7 +1,7 @@
 from __future__ import annotations
 
-ASF_APP_VERSION = "v198.26.31"
-ASF_RELEASE_NAME = "Agentic Space Factory v198.26.31"
+ASF_APP_VERSION = "v198.26.32"
+ASF_RELEASE_NAME = "Agentic Space Factory v198.26.32"
 
 
 def resolve_app_version(value: str | None = None) -> str:

src/worker_payload.py

@@ -35,8 +35,8 @@ DEFAULT_PREFERRED_SPACE_HARDWARE = "zero-a10g"
 DEFAULT_FALLBACK_SPACE_HARDWARE = "a10g-large"
 DEFAULT_MODEL_ID = "sshleifer/tiny-gpt2"
 MAX_PI_REPAIR_ATTEMPTS = 3
-APP_VERSION = "v198.26.31"
-app_version = "v198.26.31"
+APP_VERSION = "v198.26.32"
+app_version = "v198.26.32"
 
 # Internal agent/recovery files may be needed inside the transient Pi
 # workspace, but they should not be published to the generated Space or shown
@@ -4993,7 +4993,7 @@ def load_recipe_repair_context(workspace: Path | None, run_dir: Path | None) ->
         except Exception:
             runtime_contract = {}
     return {
-        "schema_version": "recipe_repair_context.v198_26_31",
+        "schema_version": "recipe_repair_context.v198_26_32",
         "model_recipe": recipe,
         "model_recipe_source": recipe_source,
         "app_runtime_contract": runtime_contract,
@@ -5047,7 +5047,7 @@ def match_recipe_known_failure_signature(error_text: str = "", recipe: dict | No
             marker_matches = marker_matches or ["CLIPTextModel.text_model"]
         if class_matches or marker_matches:
             return {
-                "schema_version": "recipe_known_failure_match.v198_26_31",
+                "schema_version": "recipe_known_failure_match.v198_26_32",
                 "matched": True,
                 "failure_class": failure_class or fallback_class,
                 "matched_markers": marker_matches[:10],
@@ -5058,8 +5058,8 @@ def match_recipe_known_failure_signature(error_text: str = "", recipe: dict | No
                 "expected_output_type": recipe.get("expected_output_type") or runtime_contract.get("expected_output_type") or "",
             }
     if fallback_class:
-        return {"schema_version": "recipe_known_failure_match.v198_26_31", "matched": False, "failure_class": fallback_class, "matched_markers": [], "repair_focus": "No catalog signature matched; still use MODEL_RECIPE.json and APP_RUNTIME_CONTRACT.json as authoritative repair context.", "source_signature": {}, "model_family": recipe.get("model_family") or runtime_contract.get("model_family") or "", "loader_strategy": recipe.get("loader_strategy") or runtime_contract.get("loader_strategy") or "", "expected_output_type": recipe.get("expected_output_type") or runtime_contract.get("expected_output_type") or ""}
-    return {"schema_version": "recipe_known_failure_match.v198_26_31", "matched": False, "failure_class": "", "matched_markers": [], "repair_focus": ""}
+        return {"schema_version": "recipe_known_failure_match.v198_26_32", "matched": False, "failure_class": fallback_class, "matched_markers": [], "repair_focus": "No catalog signature matched; still use MODEL_RECIPE.json and APP_RUNTIME_CONTRACT.json as authoritative repair context.", "source_signature": {}, "model_family": recipe.get("model_family") or runtime_contract.get("model_family") or "", "loader_strategy": recipe.get("loader_strategy") or runtime_contract.get("loader_strategy") or "", "expected_output_type": recipe.get("expected_output_type") or runtime_contract.get("expected_output_type") or ""}
+    return {"schema_version": "recipe_known_failure_match.v198_26_32", "matched": False, "failure_class": "", "matched_markers": [], "repair_focus": ""}
 
 
 def recipe_family_repair_directives(recipe: dict | None = None, runtime_contract: dict | None = None, signature_match: dict | None = None) -> list[str]:
@@ -5101,7 +5101,7 @@ def write_recipe_aware_repair_packet(workspace: Path, run_dir: Path, failure_rea
     category = str((classification or {}).get("category") or (classification or {}).get("failure_class") or (decision or {}).get("failure_class") or "")
     match = match_recipe_known_failure_signature(failure_reason, recipe, runtime_contract, fallback_class=category)
     packet = {
-        "schema_version": "recipe_aware_repair_packet.v198_26_31",
+        "schema_version": "recipe_aware_repair_packet.v198_26_32",
         "authority": "MODEL_RECIPE.json + APP_RUNTIME_CONTRACT.json",
         **ctx,
         "known_failure_match": match,
@@ -5137,7 +5137,7 @@ def should_relaunch_after_no_patch(run_dir: Path, terminal_status: str, remainin
     result = str(latest.get("post_repair_result") or "")
     result_is_no_patch = result in {"repair_noop", "expected_file_not_modified", "diff_gate_failed", "sanity_failed"}
     can_retry = remaining_patch_budget > 0 and (terminal_status in no_patch_statuses or result_is_no_patch)
-    return {"schema_version": "recipe_repair_retry_decision.v198_26_31", "relaunch": bool(can_retry), "terminal_status": terminal_status, "remaining_patch_budget": int(remaining_patch_budget or 0), "latest_attempt": latest, "reason": "retry_with_more_direct_recipe_aware_brief" if can_retry else "repair_exhausted_or_not_retryable"}
+    return {"schema_version": "recipe_repair_retry_decision.v198_26_32", "relaunch": bool(can_retry), "terminal_status": terminal_status, "remaining_patch_budget": int(remaining_patch_budget or 0), "latest_attempt": latest, "reason": "retry_with_more_direct_recipe_aware_brief" if can_retry else "repair_exhausted_or_not_retryable"}
 
 def write_smoke_repair_primary_error_packet(run_dir: Path, workspace: Path, generation_smoke: dict | None, *, failure_class: str = "") -> dict:
     smoke = generation_smoke if isinstance(generation_smoke, dict) else {}
@@ -10092,7 +10092,7 @@ def build_repair_task_packet(classification: dict, failure_reason: str = "", bui
         allowed_files = ["app.py", "INFERENCE_CONTRACT.json", "APP_RUNTIME_CONTRACT.json"]
         expected_fix = "Align the published Gradio schema and canonical smoke payload without changing model semantics; do not patch if this is validator-owned."
     packet = {
-        "schema_version": "repair_task_packet.v198_26_31",
+        "schema_version": "repair_task_packet.v198_26_32",
         "task_type": task_type,
         "repair_mode": "deep_repair_reanalysis" if is_deep_repair_category(category) else "surgical_repair",
         "patch_mode": patch_mode,
@@ -15049,7 +15049,7 @@ def load_recipe_repair_context(workspace: Path | None, run_dir: Path | None) ->
         except Exception:
             runtime_contract = {}
     return {
-        "schema_version": "recipe_repair_context.v198_26_31",
+        "schema_version": "recipe_repair_context.v198_26_32",
         "model_recipe": recipe,
         "model_recipe_source": recipe_source,
         "app_runtime_contract": runtime_contract,
@@ -15103,7 +15103,7 @@ def match_recipe_known_failure_signature(error_text: str = "", recipe: dict | No
             marker_matches = marker_matches or ["CLIPTextModel.text_model"]
         if class_matches or marker_matches:
             return {
-                "schema_version": "recipe_known_failure_match.v198_26_31",
+                "schema_version": "recipe_known_failure_match.v198_26_32",
                 "matched": True,
                 "failure_class": failure_class or fallback_class,
                 "matched_markers": marker_matches[:10],
@@ -15114,8 +15114,8 @@ def match_recipe_known_failure_signature(error_text: str = "", recipe: dict | No
                 "expected_output_type": recipe.get("expected_output_type") or runtime_contract.get("expected_output_type") or "",
             }
     if fallback_class:
-        return {"schema_version": "recipe_known_failure_match.v198_26_31", "matched": False, "failure_class": fallback_class, "matched_markers": [], "repair_focus": "No catalog signature matched; still use MODEL_RECIPE.json and APP_RUNTIME_CONTRACT.json as authoritative repair context.", "source_signature": {}, "model_family": recipe.get("model_family") or runtime_contract.get("model_family") or "", "loader_strategy": recipe.get("loader_strategy") or runtime_contract.get("loader_strategy") or "", "expected_output_type": recipe.get("expected_output_type") or runtime_contract.get("expected_output_type") or ""}
-    return {"schema_version": "recipe_known_failure_match.v198_26_31", "matched": False, "failure_class": "", "matched_markers": [], "repair_focus": ""}
+        return {"schema_version": "recipe_known_failure_match.v198_26_32", "matched": False, "failure_class": fallback_class, "matched_markers": [], "repair_focus": "No catalog signature matched; still use MODEL_RECIPE.json and APP_RUNTIME_CONTRACT.json as authoritative repair context.", "source_signature": {}, "model_family": recipe.get("model_family") or runtime_contract.get("model_family") or "", "loader_strategy": recipe.get("loader_strategy") or runtime_contract.get("loader_strategy") or "", "expected_output_type": recipe.get("expected_output_type") or runtime_contract.get("expected_output_type") or ""}
+    return {"schema_version": "recipe_known_failure_match.v198_26_32", "matched": False, "failure_class": "", "matched_markers": [], "repair_focus": ""}
 
 
 def recipe_family_repair_directives(recipe: dict | None = None, runtime_contract: dict | None = None, signature_match: dict | None = None) -> list[str]:
@@ -15157,7 +15157,7 @@ def write_recipe_aware_repair_packet(workspace: Path, run_dir: Path, failure_rea
     category = str((classification or {}).get("category") or (classification or {}).get("failure_class") or (decision or {}).get("failure_class") or "")
     match = match_recipe_known_failure_signature(failure_reason, recipe, runtime_contract, fallback_class=category)
     packet = {
-        "schema_version": "recipe_aware_repair_packet.v198_26_31",
+        "schema_version": "recipe_aware_repair_packet.v198_26_32",
         "authority": "MODEL_RECIPE.json + APP_RUNTIME_CONTRACT.json",
         **ctx,
         "known_failure_match": match,
@@ -15193,7 +15193,7 @@ def should_relaunch_after_no_patch(run_dir: Path, terminal_status: str, remainin
     result = str(latest.get("post_repair_result") or "")
     result_is_no_patch = result in {"repair_noop", "expected_file_not_modified", "diff_gate_failed", "sanity_failed"}
     can_retry = remaining_patch_budget > 0 and (terminal_status in no_patch_statuses or result_is_no_patch)
-    return {"schema_version": "recipe_repair_retry_decision.v198_26_31", "relaunch": bool(can_retry), "terminal_status": terminal_status, "remaining_patch_budget": int(remaining_patch_budget or 0), "latest_attempt": latest, "reason": "retry_with_more_direct_recipe_aware_brief" if can_retry else "repair_exhausted_or_not_retryable"}
+    return {"schema_version": "recipe_repair_retry_decision.v198_26_32", "relaunch": bool(can_retry), "terminal_status": terminal_status, "remaining_patch_budget": int(remaining_patch_budget or 0), "latest_attempt": latest, "reason": "retry_with_more_direct_recipe_aware_brief" if can_retry else "repair_exhausted_or_not_retryable"}
 
 def write_smoke_repair_primary_error_packet(run_dir: Path, workspace: Path, generation_smoke: dict | None, *, failure_class: str = "") -> dict:
     smoke = generation_smoke if isinstance(generation_smoke, dict) else {}
@@ -16670,7 +16670,7 @@ def smoke_generate(target_space_id: str, token: str, run_dir: Path, events_path:
     # write_json(run_dir / "tests" / "payload_source.json", payload_source_record)
     # write_json(run_dir / "tests" / "replay_source.json", replay_source)
     # write_json(run_dir / "tests" / "validation_preflight.json", validation_preflight)
-    app_version = "v198.26.31"
+    app_version = "v198.26.32"
     engine_version = "unified_gradio_validation_harness_v198_25_3"
     parent_build_run_id = os.environ.get("PARENT_BUILD_RUN_ID", "").strip()
     validation_mode = os.environ.get("VALIDATION_MODE") or os.environ.get("SPACE_TEST_POLICY_MODE") or "linked"