up

Signed-off-by: Rui Qiao <ruisearch42@gmail.com>
vllm-project · Dec 13, 2024 · f33563f · f33563f
1 parent fe5b66f
commit f33563f
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/vllm/distributed/parallel_state.py b/vllm/distributed/parallel_state.py
@@ -247,9 +247,9 @@ def __init__(
         from vllm.distributed.device_communicators.shm_broadcast import (
             MessageQueue)
         self.mq_broadcaster: Optional[MessageQueue] = None
-        # if use_message_queue_broadcaster and self.world_size > 1:
-        #     self.mq_broadcaster = MessageQueue.create_from_process_group(
-        #         self.cpu_group, 1 << 22, 6)
+        if use_message_queue_broadcaster and self.world_size > 1:
+            self.mq_broadcaster = MessageQueue.create_from_process_group(
+                self.cpu_group, 1 << 22, 6)
 
     @property
     def first_rank(self):