diff --git a/vllm/engine/multiprocessing/client.py b/vllm/engine/multiprocessing/client.py index 8988e6051f119..d5636b606e00a 100644 --- a/vllm/engine/multiprocessing/client.py +++ b/vllm/engine/multiprocessing/client.py @@ -387,7 +387,9 @@ async def abort(self, request_id: str): with suppress(MQClientClosedError): await self._send_one_way_rpc_request( - request=RPCAbortRequest(request_id), socket=self.input_socket) + request=RPCAbortRequest(request_id), + secret_key=self.secret_key, + socket=self.input_socket) async def do_log_stats( self,