fix(ci): use NATS events for loopback Slurm tests

Signed-off-by: functionstackx <47992694+functionstackx@users.noreply.github.com>

Author: functionstackx

scripts/ci/README.md

@@ -99,8 +99,10 @@ scratch bind mount inside the test container. The account's real home is not
 mounted, `HOME` is unchanged, and the image and pinned model snapshot stay
 read-only during testing.
 
-This single-node lane binds Dynamo's HTTP, system, request, response and event
-interfaces to loopback. Listener evidence covers the five named service ports
+This single-node lane binds Dynamo's HTTP, system, request and response
+interfaces to loopback and sends events through the existing loopback NATS
+service (`DYN_EVENT_PLANE=nats`). Direct ZMQ publishers bind a wildcard even when
+their advertised host is loopback. Listener evidence covers the five named service ports
 and every TCP listener owned by the frontend and worker system-endpoint PIDs.
 It does not claim to inventory unrelated engine subprocess sockets.
 

scripts/ci/barite_client.py

@@ -626,6 +626,14 @@ def main():
 if __name__ == "__main__":
     try:
         main()
+    except (subprocess.CalledProcessError, subprocess.TimeoutExpired) as error:
+        print(f"Barite CI: {error}", file=sys.stderr)
+        if error.stderr:
+            detail = error.stderr
+            if isinstance(detail, bytes):
+                detail = detail.decode("utf-8", errors="replace")
+            print(detail[-8192:], file=sys.stderr)
+        sys.exit(1)
     except (ValueError, OSError, KeyError, subprocess.SubprocessError) as error:
         print(f"Barite CI: {error}", file=sys.stderr)
         sys.exit(1)

scripts/ci/rocm/run_tests.py

@@ -40,7 +40,9 @@ def main():
         # All cooperating Dynamo services share this one-node allocation.
         DYN_TCP_RPC_HOST="127.0.0.1",
         DYN_TCP_RESPONSE_STREAM_HOST="127.0.0.1",
-        DYN_EVENT_PLANE_HOST="127.0.0.1",
+        # Direct ZMQ publishers bind a wildcard even with a loopback advertised
+        # host. Use the existing loopback NATS service for this one-node lane.
+        DYN_EVENT_PLANE="nats",
     )
     contract = json.loads(Path(__file__).with_name("contract.json").read_text())
     request = json.loads((result / "request.json").read_text())