diff --git a/src/gen_worker/models/download.py b/src/gen_worker/models/download.py index 4886136c..6a4c1da0 100644 --- a/src/gen_worker/models/download.py +++ b/src/gen_worker/models/download.py @@ -45,8 +45,7 @@ # # ONE keying function (gw#492) normalizes both index keys and lookups — # replacing the old raw/stripped/tag-removed fallback chain and its -# `_binding_canonical_ref` twin. Keys are flavor-granular (a dispatch table -# may bind two providers to one repo name via different flavors) with a +# `_binding_canonical_ref` twin. Keys are flavor-granular, with a # repo-identity fallback so hub-minted picks of NEW flavors (`#svdq-int4`) # still route to their repo's provider. # --------------------------------------------------------------------------- @@ -117,11 +116,6 @@ def _collect_binding_entries(bindings: Any) -> list[dict[str, Any]]: for entry in bindings.values(): if not isinstance(entry, dict): continue - if str(entry.get("kind") or "").strip() == "dispatch": - table = entry.get("table") - if isinstance(table, dict): - out.extend(sub for sub in table.values() if isinstance(sub, dict)) - continue if entry.get("ref"): out.append(entry) return out diff --git a/tests/test_provider_routing.py b/tests/test_provider_routing.py index 4266a497..6b8965ef 100644 --- a/tests/test_provider_routing.py +++ b/tests/test_provider_routing.py @@ -74,12 +74,11 @@ def _manifest(*binding_blocks: dict) -> dict: {"acme/flux:canary#fp8": "tensorhub"}, ), ( - # Dispatch table: one repo name, two providers per flavor variant. + # th#928: retired dispatch-kind entries are ignored, not parsed. {"pipeline": {"kind": "dispatch", "field": "variant", "table": { "bf16": {"provider": "hf", "ref": "owner/flux", "flavor": "bf16"}, - "fp8": {"provider": "tensorhub", "ref": "owner/flux", "flavor": "fp8"}, }}}, - {"owner/flux#bf16": "hf", "owner/flux#fp8": "tensorhub"}, + {"owner/flux#bf16": None}, ), ], )