Restore VisA startup when dataset server is unavailable

.gitattributes

@@ -1 +0,0 @@
-vendor/hyperview-0.6.3.dev0+g1ddcd10b5.d20260607-py3-none-any.whl filter=lfs diff=lfs merge=lfs -text

.hyperview/extensions/manufacturing-readout/panel.js

@@ -18,9 +18,6 @@ const colors = {
   goodBg: "#132018",
   accent: "#8fb8ff",
   error: "#fca5a5",
-  warningBg: "#3b2f12",
-  warningBorder: "#92400e",
-  warningText: "#fde68a",
 };
 
 function pretty(value) {
@@ -485,7 +482,6 @@ export default function ManufacturingPanel() {
   const models = normalizeModels(props.models);
   const examples = Array.isArray(props.examples) ? props.examples : [];
   const primaryExample = examples.find((item) => item.id === "fryum") || examples[0] || null;
-  const warnings = Array.isArray(props.warnings) ? props.warnings : [];
   const [loadingKey, setLoadingKey] = React.useState(null);
   const [panelError, setPanelError] = React.useState(null);
   const [activeChoice, setActiveChoice] = React.useState(null);
@@ -604,24 +600,6 @@ export default function ManufacturingPanel() {
             panelError,
           )
         : null,
-      warnings.map((warning, index) =>
-        React.createElement(
-          "div",
-          {
-            key: index,
-            style: {
-              border: `1px solid ${colors.warningBorder}`,
-              background: colors.warningBg,
-              color: colors.warningText,
-              borderRadius: 5,
-              padding: 8,
-              fontSize: 11,
-              lineHeight: 1.35,
-            },
-          },
-          warning,
-        ),
-      ),
       React.createElement(StrengthTable, { rows: Array.isArray(props.strengthRows) ? props.strengthRows : [] }),
     ),
   );

README.md

@@ -63,6 +63,4 @@ The Docker image installs the bundled latest HyperView wheel for this repo and
 uses HyperView's public dataset, UI, and panel command APIs. Hyper3-CLIP loads
 through the public `hyper-models` provider catalog entry for the gated
 `hyper3labs/hyper3-clip-v0.5` model repository. The Space needs an `HF_TOKEN`
-secret with access to that model. If unavailable, the Space can start with a
-clearly labeled CLIP fallback unless `HYPERVIEW_ALLOW_CANDIDATE_FALLBACK=0` is
-set.
+secret with access to that model; startup fails if the model cannot be loaded.

demo.py

@@ -29,18 +29,14 @@ EXTENSION_DIR = SPACE_DIR / ".hyperview" / "extensions" / "manufacturing-readout
 SAMPLES_PER_CATEGORY = int(os.environ.get("VISA_SAMPLES_PER_CATEGORY", "4"))
 TRAIN_FRACTION = float(os.environ.get("VISA_TRAIN_FRACTION", "0.5"))
 IMAGE_MAX_SIZE = (640, 640)
+VISA_DATASET_ID = "BrachioLab/visa"
+VISA_DATASET_REVISION = "d185c42584b49f1df81fe12bde627559ed88d483"
 FORCE_SAMPLE_REFRESH = os.environ.get("HYPERVIEW_VISA_FORCE_REFRESH", "").lower() in {
     "1",
     "true",
     "yes",
 }
-ALLOW_CANDIDATE_FALLBACK = os.environ.get("HYPERVIEW_ALLOW_CANDIDATE_FALLBACK", "1").lower() in {
-    "1",
-    "true",
-    "yes",
-}
-RUNTIME_WARNINGS: list[str] = []
-
+DATASET_SERVER_UNAVAILABLE = False
 VISA_CATEGORIES = (
     "candle",
     "capsules",
@@ -123,9 +119,11 @@ def readable(value: str) -> str:
 
 
 def fetch_rows(split: str, count: int) -> list[dict[str, Any]]:
+    global DATASET_SERVER_UNAVAILABLE
+
     params = urllib.parse.urlencode(
         {
-            "dataset": "BrachioLab/visa",
+            "dataset": VISA_DATASET_ID,
             "config": "default",
             "split": split,
             "offset": 0,
@@ -134,22 +132,45 @@ def fetch_rows(split: str, count: int) -> list[dict[str, Any]]:
     )
     url = f"https://datasets-server.huggingface.co/rows?{params}"
     last_error: Exception | None = None
-    for attempt in range(1, 5):
-        try:
-            with urllib.request.urlopen(url, timeout=60) as response:
-                payload = json.loads(response.read().decode("utf-8"))
-            break
-        except Exception as exc:
-            last_error = exc
-            if attempt == 4:
-                raise
-            time.sleep(1.5 * attempt)
-    else:
-        raise RuntimeError(f"Could not fetch VisA split {split}") from last_error
-    rows = [item["row"] for item in payload["rows"]]
+    if not DATASET_SERVER_UNAVAILABLE:
+        for attempt in range(1, 5):
+            try:
+                with urllib.request.urlopen(url, timeout=60) as response:
+                    payload = json.loads(response.read().decode("utf-8"))
+                rows = [item["row"] for item in payload["rows"]]
+                if len(rows) < count:
+                    raise RuntimeError(f"Split {split} returned {len(rows)} rows for requested count {count}")
+                return rows[:count]
+            except Exception as exc:
+                last_error = exc
+                if attempt < 4:
+                    time.sleep(1.5 * attempt)
+        DATASET_SERVER_UNAVAILABLE = True
+        print(
+            f"VisA dataset-server rows unavailable ({type(last_error).__name__}: {last_error}); "
+            "falling back to the pinned Hub dataset.",
+            flush=True,
+        )
+
+    try:
+        from datasets import load_dataset
+
+        stream = load_dataset(
+            VISA_DATASET_ID,
+            split=split,
+            revision=VISA_DATASET_REVISION,
+            streaming=True,
+        )
+        rows = []
+        for row in stream:
+            rows.append(row)
+            if len(rows) >= count:
+                break
+    except Exception as exc:
+        raise RuntimeError(f"Could not fetch pinned VisA split {split} from the Hub") from exc
     if len(rows) < count:
-        raise RuntimeError(f"Split {split} returned {len(rows)} rows for requested count {count}")
-    return rows[:count]
+        raise RuntimeError(f"Split {split} returned {len(rows)} rows for requested count {count}") from last_error
+    return rows
 
 
 def local_records(category: str, split_type: str, count: int) -> list[dict[str, Any]]:
@@ -175,11 +196,16 @@ def local_records(category: str, split_type: str, count: int) -> list[dict[str,
     return records[:count]
 
 
-def save_url_image(url: str, destination: Path) -> None:
+def save_image(source: Any, destination: Path) -> None:
     if destination.exists() and destination.stat().st_size > 0:
         return
-    with urllib.request.urlopen(url, timeout=60) as response:
-        image = Image.open(io.BytesIO(response.read()))
+    if isinstance(source, str):
+        with urllib.request.urlopen(source, timeout=60) as response:
+            image = Image.open(io.BytesIO(response.read()))
+    elif isinstance(source, Image.Image):
+        image = source
+    else:
+        raise TypeError(f"Unsupported VisA image source: {type(source).__name__}")
     image = ImageOps.exif_transpose(image).convert("RGB")
     image.thumbnail(IMAGE_MAX_SIZE, Image.Resampling.LANCZOS)
     tmp_path = destination.with_suffix(destination.suffix + ".tmp")
@@ -202,10 +228,11 @@ def select_visa_records() -> list[dict[str, Any]]:
             split_name = f"{category}.{split_type}"
             rows = fetch_rows(split_name, count)
             for row_index, row in enumerate(rows):
+                image = row["image"]
                 records.append(
                     {
                         "row_index": row_index,
-                        "image_url": row["image"]["src"],
+                        "image_source": image["src"] if isinstance(image, dict) else image,
                         "local_path": None,
                         "category": category,
                         "family": FAMILY_BY_CATEGORY[category],
@@ -226,8 +253,8 @@ def add_visa_samples(dataset: hv.Dataset) -> None:
     for record in select_visa_records():
         sample_id = safe_sample_id(record["category"], record["split_name"], record["row_index"], record["defect_label"])
         destination = Path(record["local_path"]) if record.get("local_path") else media_dir / f"{sample_id}.jpg"
-        if record.get("image_url"):
-            save_url_image(record["image_url"], destination)
+        if record.get("image_source") is not None:
+            save_image(record["image_source"], destination)
         metadata = {
             "sku": record["category"],
             "product_family": record["family"],
@@ -257,36 +284,12 @@ def ensure_layouts(dataset: hv.Dataset) -> dict[str, str]:
     layouts: dict[str, str] = {}
     for spec in MODEL_SPECS:
         print(f"Ensuring {spec['display_name']} embeddings...", flush=True)
-        try:
-            space_key = dataset.compute_embeddings(
-                model=spec["model"],
-                provider=spec["provider"],
-                batch_size=32,
-                show_progress=True,
-            )
-        except Exception as exc:
-            if spec["key"] == "candidate" and ALLOW_CANDIDATE_FALLBACK and "clip" in layouts:
-                warning = (
-                    f"Hyper3-CLIP embeddings are unavailable ({type(exc).__name__}: {exc}). "
-                    "Showing the CLIP layout as a clearly labeled fallback so the Space can start."
-                )
-                print(warning, flush=True)
-                RUNTIME_WARNINGS.append(warning)
-                fallback_layout_key = layouts["clip"]
-                spec.update(
-                    {
-                        "display_name": "Hyper3-CLIP unavailable (CLIP fallback)",
-                        "button_label": "CLIP fallback query",
-                        "geometry": MODEL_SPECS[0]["geometry"],
-                        "layout_dimension": MODEL_SPECS[0]["layout_dimension"],
-                        "panel_title": "Hyper3-CLIP unavailable - showing CLIP fallback",
-                        "fallback": True,
-                        "layout_key": fallback_layout_key,
-                    }
-                )
-                layouts[spec["key"]] = fallback_layout_key
-                continue
-            raise
+        space_key = dataset.compute_embeddings(
+            model=spec["model"],
+            provider=spec["provider"],
+            batch_size=32,
+            show_progress=True,
+        )
         print(f"Ensuring {spec['display_name']} layout...", flush=True)
         layout_key = dataset.compute_visualization(
             space_key=space_key,
@@ -376,16 +379,10 @@ def build_examples(dataset: hv.Dataset) -> list[dict[str, Any]]:
         if sample.metadata.get("workflow_role") == "inspection_query":
             by_category.setdefault(sample.label, sample)
     examples = []
-    candidate_is_fallback = any(spec["key"] == "candidate" and spec.get("fallback") for spec in MODEL_SPECS)
     for category, family_title in PREFERRED_EXAMPLES:
         sample = by_category.get(category)
         if sample is None:
             continue
-        candidate_text = (
-            "Hyper3-CLIP is unavailable in this runtime, so this button shows the CLIP fallback neighborhood."
-            if candidate_is_fallback
-            else "Inspect whether normal references and same-SKU examples stay ahead of wrong-line neighbors."
-        )
         examples.append(
             {
                 "id": category,
@@ -399,7 +396,7 @@ def build_examples(dataset: hv.Dataset) -> list[dict[str, Any]]:
                         **reference_summary(dataset, sample.id, "clip"),
                     },
                     "candidate": {
-                        "text": candidate_text,
+                        "text": "Inspect whether normal references and same-SKU examples stay ahead of wrong-line neighbors.",
                         **reference_summary(dataset, sample.id, "candidate"),
                     },
                 },
@@ -461,7 +458,6 @@ def build_demo_view(dataset: hv.Dataset, layouts: dict[str, str]) -> hv.ui.View:
                 "models": model_panel_props(layouts),
                 "examples": build_examples(dataset),
                 "strengthRows": category_strength_rows(dataset),
-                "warnings": RUNTIME_WARNINGS,
             },
         ),
         hv.ui.Samples(