diff --git a/vllm/v1/engine/core.py b/vllm/v1/engine/core.py index 4de3e4ea7d3a..0c5cc29bf20f 100644 --- a/vllm/v1/engine/core.py +++ b/vllm/v1/engine/core.py @@ -1571,7 +1571,11 @@ def add_request(self, request: Request, request_wave: int = 0): 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))