Propagate layout_aborted @9a25031

tools/hf_space/runner.py

@@ -456,6 +456,11 @@ def _validate_zip_streaming(*, api: HfApi, dataset: str, token: str | None,
 
     merged_results: list[dict] = []
     merged_layout: list[dict] = []
+    # Set when ANY processed unit's results.json carries
+    # layout_aborted=true (the validator's strict pre-check fired).
+    # Propagated into the final dict so the dashboard sees the flag
+    # and renders the layout-failed banner instead of generic counts.
+    any_layout_aborted = False
     workers = os.environ.get("SR_WORKERS", "4").strip() or "4"
     cache_hits = 0
     val_ver = _validator_version()
@@ -551,7 +556,7 @@ def _validate_zip_streaming(*, api: HfApi, dataset: str, token: str | None,
         nonlocal cache_hits, zips_processed, profile_autodetect_done
         nonlocal profile, consecutive_unrecoverable, was_cancelled
         nonlocal use_plugin_default, issue_filed_for_registration_bug
-        nonlocal issue_filing_disabled
+        nonlocal issue_filing_disabled, any_layout_aborted
         # Honor early abort (cancel or unrecoverable failure) — tasks
         # queued before the stop signal still get scheduled and have
         # to no-op themselves.
@@ -589,6 +594,8 @@ def _validate_zip_streaming(*, api: HfApi, dataset: str, token: str | None,
             if cached:
                 merged_results.extend(cached.get("results", []))
                 merged_layout.extend(cached.get("layout_findings") or [])
+                if cached.get("layout_aborted"):
+                    any_layout_aborted = True
                 cache_hits += 1
                 out(f"  [{i+1}/{len(zip_entries)}] cache hit: {zip_rel} "
                     f"({len(cached.get('results', []))} asset(s))")
@@ -781,6 +788,8 @@ def _validate_zip_streaming(*, api: HfApi, dataset: str, token: str | None,
                 zip_layout = rj.get("layout_findings") or []
                 merged_results.extend(zip_results)
                 merged_layout.extend(zip_layout)
+                if rj.get("layout_aborted"):
+                    any_layout_aborted = True
                 out(f"    {len(zip_results)} asset(s); rc={rc}")
                 # Emit a progress write so the dashboard sees the
                 # updated zip-count + per-asset rows immediately
@@ -801,6 +810,7 @@ def _validate_zip_streaming(*, api: HfApi, dataset: str, token: str | None,
                         "zip_sha": zip_sha,
                         "results": zip_results,
                         "layout_findings": zip_layout,
+                        "layout_aborted": bool(rj.get("layout_aborted")),
                         "validator_version": val_ver,
                         "foundation_sha": found_sha,
                         "profile": profile,
@@ -890,6 +900,7 @@ def _validate_zip_streaming(*, api: HfApi, dataset: str, token: str | None,
         "schema_version": 1,
         "results": merged_results,
         "layout_findings": merged_layout,
+        "layout_aborted": any_layout_aborted,
         "profile_coverage": {},
         "streaming_zips": len(zip_entries),
         "streaming_cache_hits": cache_hits,