Upload 15 files

src/version.py

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

src/worker_payload.py

@@ -40,8 +40,8 @@ DEFAULT_FALLBACK_SPACE_HARDWARE = "a10g-large"
 DEFAULT_MODEL_ID = "sshleifer/tiny-gpt2"
 MAX_PI_REPAIR_ATTEMPTS = 3
 DEFAULT_FACTORY_UPLOAD_RETRY_BUDGET = 1
-APP_VERSION = "v198.26.87"
-app_version = "v198.26.87"
+APP_VERSION = "v198.26.89"
+app_version = "v198.26.89"
 
 # Internal agent/recovery files may be needed inside the transient Pi
 # workspace, but they should not be published to the generated Space or shown
@@ -3375,6 +3375,23 @@ def gradio_file_kind_for_param(param: dict) -> str:
     return ""
 
 
+def gradio_file_list_for_param(param: dict) -> bool:
+    """Return true when a file-backed Gradio parameter expects a list payload."""
+    if not isinstance(param, dict):
+        return False
+    name = str(param.get("name") or "").strip().lower().replace(" ", "_").replace("-", "_")
+    component = str(param.get("component") or "").lower()
+    haystack = f"{name} {component}"
+    if "gallery" in haystack or "gallerydata" in haystack:
+        return True
+    name_parts = {part for part in re.split(r"[^a-z0-9]+", name) if part}
+    return bool(name_parts & {"images", "videos", "audios", "files"})
+
+
+def _is_gradio_file_data_dict(value) -> bool:
+    return isinstance(value, dict) and (value.get("meta") or {}).get("_type") == "gradio.FileData"
+
+
 def ensure_smoke_input_file(run_dir: Path, kind: str) -> str:
     smoke_dir = run_dir / "tests" / "smoke_inputs"
     smoke_dir.mkdir(parents=True, exist_ok=True)
@@ -3483,7 +3500,40 @@ def prepare_gradio_file_inputs(args: list, params: list[dict], run_dir: Path) ->
         if not kind:
             continue
         before = resolved[index]
-        if isinstance(before, dict) and (before.get("meta") or {}).get("_type") == "gradio.FileData":
+        if gradio_file_list_for_param(param):
+            values = before if isinstance(before, list) else [before]
+            converted = []
+            item_conversions = []
+            for item_index, item in enumerate(values):
+                if _is_gradio_file_data_dict(item):
+                    converted.append(item)
+                    item_conversions.append({
+                        "item_index": item_index,
+                        "from_type": type(item).__name__,
+                        "action": "already_filedata",
+                    })
+                    continue
+                source, resolution = resolve_smoke_file_source(run_dir, item, kind)
+                converted.append(handle_file(str(source)))
+                item_conversions.append({
+                    "item_index": item_index,
+                    "from_type": type(item).__name__,
+                    "source": str(source)[:500],
+                    "action": "handle_file",
+                    "resolution": resolution,
+                })
+            resolved[index] = converted
+            conversions.append({
+                "index": index,
+                "name": str(param.get("name") or f"arg{index}"),
+                "kind": kind,
+                "from_type": type(before).__name__,
+                "action": "handle_file_list",
+                "item_count": len(converted),
+                "items": item_conversions,
+            })
+            continue
+        if _is_gradio_file_data_dict(before):
             continue
         try:
             source, resolution = resolve_smoke_file_source(run_dir, before, kind)
@@ -16620,6 +16670,20 @@ def _schema_file_kind(param, index: int) -> str:
     return ""
 
 
+def _schema_file_list_for_param(param, index: int) -> bool:
+    name = _schema_name(param, index).lower().replace(" ", "_").replace("-", "_")
+    component = _schema_component(param)
+    haystack = f"{name} {component}"
+    if "gallery" in haystack or "gallerydata" in haystack:
+        return True
+    name_parts = {part for part in re.split(r"[^a-z0-9]+", name) if part}
+    return bool(name_parts & {"images", "videos", "audios", "files"})
+
+
+def _is_validation_filedata_dict(value) -> bool:
+    return isinstance(value, dict) and (value.get("meta") or {}).get("_type") == "gradio.FileData"
+
+
 def _is_validation_url_like(value) -> bool:
     text = str(value or "").strip().lower()
     return text.startswith(("http://", "https://", "hf://", "s3://", "gs://", "data:"))
@@ -16703,7 +16767,28 @@ def prepare_validation_file_inputs(api_name: str, schema, args: list, run_dir: P
         if not kind:
             continue
         before = resolved[index]
-        if isinstance(before, dict) and (before.get("meta") or {}).get("_type") == "gradio.FileData":
+        if _schema_file_list_for_param(param, index):
+            values = before if isinstance(before, list) else [before]
+            converted = []
+            item_conversions = []
+            for item_index, item in enumerate(values):
+                if _is_validation_filedata_dict(item):
+                    converted.append(item)
+                    item_conversions.append({"item_index": item_index, "from_type": type(item).__name__, "action": "already_filedata"})
+                    continue
+                source = item
+                source_text = str(source or "").strip()
+                if kind in {"image", "audio", "file"} and (source is None or not _validation_media_source_is_usable(source)):
+                    source = _ensure_validation_input_file(run_dir, kind)
+                converted.append(handle_file(str(source)))
+                action = "handle_file"
+                if source_text and str(source) != source_text:
+                    action = "replaced_unusable_media_source_with_smoke_file"
+                item_conversions.append({"item_index": item_index, "from_type": type(item).__name__, "source": str(source)[:500], "original_source": source_text[:500], "action": action})
+            resolved[index] = converted
+            conversions.append({"index": index, "name": _schema_name(param, index), "kind": kind, "from_type": type(before).__name__, "action": "handle_file_list", "item_count": len(converted), "items": item_conversions})
+            continue
+        if _is_validation_filedata_dict(before):
             continue
         source = before
         source_text = str(source or "").strip()
@@ -18992,7 +19077,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.87"
+    app_version = "v198.26.89"
     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"