From 4c81772e8bdf9e37ab2b8adfd80e4308b618fa92 Mon Sep 17 00:00:00 2001 From: AlexHuang Date: Mon, 13 Jul 2026 01:00:04 +0800 Subject: [PATCH] [Bugfix][KV Offloading] Fix stale transfer_jobs after reset_cache + harden job completion (#48102) Signed-off-by: Alex --- .../kv_transfer/kv_connector/v1/offloading/scheduler.py | 1 + 1 file changed, 1 insertion(+) diff --git a/vllm/distributed/kv_transfer/kv_connector/v1/offloading/scheduler.py b/vllm/distributed/kv_transfer/kv_connector/v1/offloading/scheduler.py index 75a9696b72c..f896c9cc492 100644 --- a/vllm/distributed/kv_transfer/kv_connector/v1/offloading/scheduler.py +++ b/vllm/distributed/kv_transfer/kv_connector/v1/offloading/scheduler.py @@ -1310,6 +1310,7 @@ class OffloadingConnectorScheduler: for status in self._req_status.values(): for group_state in status.group_states: group_state.next_stored_block_idx = 0 + status.transfer_jobs.clear() # Discard jobs and save job_counter to be able to discard worker responses self._stale_job_threshold = self._job_counter