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