From 2dccb38f73fa79bc629b8b215b8066e61ce4a211 Mon Sep 17 00:00:00 2001 From: zhanqiuhu <49648934+ZhanqiuHu@users.noreply.github.com> Date: Mon, 16 Mar 2026 16:51:04 -0400 Subject: [PATCH] [Bugfix][MultiConnector] Fix MultiConnector for SupportsHMA sub-connectors (#36549) --- .../kv_transfer/kv_connector/v1/nixl_connector.py | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/vllm/distributed/kv_transfer/kv_connector/v1/nixl_connector.py b/vllm/distributed/kv_transfer/kv_connector/v1/nixl_connector.py index 973cb572c..7651bf988 100644 --- a/vllm/distributed/kv_transfer/kv_connector/v1/nixl_connector.py +++ b/vllm/distributed/kv_transfer/kv_connector/v1/nixl_connector.py @@ -415,6 +415,14 @@ class NixlConnector(KVConnectorBase_V1, SupportsHMA): assert self.connector_scheduler is not None return self.connector_scheduler.build_connector_meta(scheduler_output) + def request_finished( + self, + request: "Request", + block_ids: list[int], + ) -> tuple[bool, dict[str, Any] | None]: + assert self.connector_scheduler is not None + return self.connector_scheduler.request_finished(request, (block_ids,)) + def request_finished_all_groups( self, request: "Request",