[Fix] Fix abort in dp (#1767)

2024-10-23 10:46:29 -07:00
parent fbcbb26327
commit 9af7b88e3c
1 changed files with 1 additions and 1 deletions
--- a/python/sglang/srt/managers/data_parallel_controller.py
+++ b/python/sglang/srt/managers/data_parallel_controller.py
@@ -156,7 +156,7 @@ class DataParallelController:
                else:
                    # Send other control messages to all workers
                    for worker in self.workers:
-                        worker.queue.put(recv_req)
+                        worker.send_pyobj(recv_req)


 def run_data_parallel_controller_process(