From 9af7b88e3cbb3afea3a3b71ffd2b984fcbed58bb Mon Sep 17 00:00:00 2001 From: Lianmin Zheng Date: Wed, 23 Oct 2024 10:46:29 -0700 Subject: [PATCH] [Fix] Fix abort in dp (#1767) --- python/sglang/srt/managers/data_parallel_controller.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/python/sglang/srt/managers/data_parallel_controller.py b/python/sglang/srt/managers/data_parallel_controller.py index 1b7da747f..450c62020 100644 --- 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(