[Bugfix][EP+DP] Fix internode check

Signed-off-by: Tyler Michael Smith <tysmith@redhat.com>

Author: tlrmchlsmth

vllm/distributed/device_communicators/all2all.py

@@ -178,7 +178,6 @@ def _make_all2all_kwargs(self) -> dict[Any, Any]:
             num_rdma_bytes = 1024 * 1024 * 1024
             num_qps_per_rank = self.num_sms // 2
         else:
-            assert self.intranode
             num_rdma_bytes = 0
             num_qps_per_rank = 1
 
@@ -243,7 +242,6 @@ def _make_all2all_kwargs(
         if self.internode:
             num_rdma_bytes = 1024 * 1024 * 1024
         else:
-            assert self.intranode
             num_rdma_bytes = deep_ep.Buffer.get_low_latency_rdma_size_hint(
                 num_max_dispatch_tokens_per_rank=max_num_tokens_per_dp_rank,
                 hidden=token_hidden_size,

vllm/distributed/device_communicators/base_device_communicator.py

@@ -49,8 +49,7 @@ def __init__(self, cpu_group):
 
         # all2all communication often has separate implementations for
         # intra-node and inter-node communication
-        self.intranode = in_the_same_node_as(cpu_group, source_rank=0)
-        self.internode = not self.intranode
+        self.internode = not all(in_the_same_node_as(cpu_group, source_rank=0))
 
     def get_handle(self, kwargs):
         # get a handle for the all2all communication,