diff --git a/vllm/v1/engine/core_client.py b/vllm/v1/engine/core_client.py index 5a256895ca7e7..1662577b837d9 100644 --- a/vllm/v1/engine/core_client.py +++ b/vllm/v1/engine/core_client.py @@ -977,7 +977,6 @@ class DPAsyncMPClient(AsyncMPClient): chosen_engine = self.get_core_engine_for_request(request) to_await = self._send_input(EngineCoreRequestType.ADD, request, chosen_engine) - if not self.engines_running: # Notify coordinator that we're sending a request req_msg = msgspec.msgpack.encode(("FIRST_REQ", chosen_engine))