From f22ff2958c398ae0950598cdbb9c677c027fa5db Mon Sep 17 00:00:00 2001 From: Jaewon <52840625+jaewonlee-fb@users.noreply.github.com> Date: Tue, 3 Mar 2026 16:10:11 -0800 Subject: [PATCH] [Bugfix] Fix coord_socket assertion in DPEngineCoreProc for offline DP mode (#35916) Signed-off-by: Jaewon Lee --- vllm/v1/engine/core.py | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/vllm/v1/engine/core.py b/vllm/v1/engine/core.py index 4de3e4ea7..0c5cc29bf 100644 --- a/vllm/v1/engine/core.py +++ b/vllm/v1/engine/core.py @@ -1571,7 +1571,11 @@ class DPEngineCoreProc(EngineCoreProc): def resume_scheduler(self): super().resume_scheduler() - if not self.engines_running and self.scheduler.has_unfinished_requests(): + if ( + self.has_coordinator + and not self.engines_running + and self.scheduler.has_unfinished_requests() + ): # Wake up other DP engines. self.output_queue.put_nowait( (-1, EngineCoreOutputs(start_wave=self.current_wave))