diff --git a/vllm/distributed/kv_transfer/kv_connector/v1/moriio_connector.py b/vllm/distributed/kv_transfer/kv_connector/v1/moriio_connector.py index 877811a64a8d3..068bc6f096297 100644 --- a/vllm/distributed/kv_transfer/kv_connector/v1/moriio_connector.py +++ b/vllm/distributed/kv_transfer/kv_connector/v1/moriio_connector.py @@ -1993,7 +1993,7 @@ class MoRIIOConnectorWorker: meta.remote_engine_id = remote_engine_id - self.get_engine_name_with_dp(remote_engine_id, 0) + dp0_remote_engine_id = self.get_engine_name_with_dp(remote_engine_id, 0) if dp0_remote_engine_id not in self._remote_agents: # Initiate handshake with remote engine to exchange metadata. with self._handshake_lock: