Upload Quasar_axrvi_ranker.py

Quasar_axrvi_ranker.py

@@ -5059,7 +5059,21 @@ class ShreveRankingEngine:
 
         results: List[RankedAsset] = []
 
-        for space_name, snap in snapshots.items():
+        # FIX: iterate over ALL configured asset symbols, not just hub snapshots.
+        # hub_snapshots only contains assets whose publisher has connected — if any
+        # space has not yet sent a metrics_update the snapshot is missing and that
+        # asset is silently dropped from the ranking, causing the executor to see
+        # only the one asset whose space happens to be the active publisher.
+        _all_asset_ids = (
+            list(self.asset_buffers.keys()) if self.asset_buffers
+            else list(snapshots.keys())
+        )
+        for space_name in _all_asset_ids:
+            snap = snapshots.get(space_name)
+            if snap is None:
+                # Asset has no hub snapshot yet — create a neutral default so it
+                # participates in ranking with zero significance weight.
+                snap = AssetSnapshot(space_name=space_name)
             acc   = snap.avn_accuracy
             # Raw neural significance — no hub_confidence multiplier, no Gaussian
             # lower-bound. Cross-asset competition is handled by low-τ softmax
@@ -8279,11 +8293,20 @@ class QuasarAXRVIBridge:
         try:
             import urllib.request as _urlreq
 
-            # Build payload with flip_direction from each asset's snapshot
+            # Build payload with flip_direction from each asset's snapshot.
+            # FIX: fall back to r.dominant_signal (from rank_risk_neutral, which
+            # reads snap.dominant_signal at ranking time) when the snapshot is
+            # missing or still NEUTRAL — prevents all non-publishing assets from
+            # being broadcast with flip_direction="NEUTRAL" which blocks Gate A.
             rankings_payload = []
             for r in ranked:
                 snap = self.hub_subscriber.get_snapshot(r.space_name)
-                flip_dir = snap.dominant_signal if snap else "NEUTRAL"
+                snap_signal = snap.dominant_signal if snap else "NEUTRAL"
+                flip_dir = (
+                    snap_signal
+                    if snap_signal not in ("NEUTRAL", "NONE", None, "")
+                    else r.dominant_signal   # set from snap at rank_risk_neutral time
+                )
                 rankings_payload.append({
                     "space_name":        r.space_name,
                     "score":             r.score,