From 9e15ce7074542f8751bd1c4354be5af8fbbfccd0 Mon Sep 17 00:00:00 2001 From: liziyu <56102866+liziyu179@users.noreply.github.com> Date: Tue, 21 Apr 2026 22:23:21 +0800 Subject: [PATCH] [Bugfix] [P/D] Fix connector with pcp dcp (#8538) ### What this PR does / why we need it? Fix the issue where a request does not return due to a specific NPU on node D having no transmission tasks in the scenario where node D is enabled with DCP. ### Does this PR introduce _any_ user-facing change? ### How was this patch tested? by nightly Signed-off-by: liziyu --- .../distributed/kv_transfer/kv_p2p/mooncake_connector.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/vllm_ascend/distributed/kv_transfer/kv_p2p/mooncake_connector.py b/vllm_ascend/distributed/kv_transfer/kv_p2p/mooncake_connector.py index 95d05fdc..4c692e33 100644 --- a/vllm_ascend/distributed/kv_transfer/kv_p2p/mooncake_connector.py +++ b/vllm_ascend/distributed/kv_transfer/kv_p2p/mooncake_connector.py @@ -442,8 +442,7 @@ class KVCacheRecvingThread(threading.Thread): finally: self._send_done_signal_to_free_remote_port(remote_request_id, remote_host, remote_port_send_num) if all_task_done: - if len(req_meta["local_block_ids"]) > 0: - self.task_tracker.update_done_task_count(request_id) + self.task_tracker.update_done_task_count(request_id) if request_id in self.proc_not_transfer_request: del self.proc_not_transfer_request[request_id] self.request_queue.task_done()