apps/FastDeploy
1
0
Fork 0
mirror of https://github.com/PaddlePaddle/FastDeploy.git synced 2025-10-05 16:48:03 +08:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

fix bug for scheduler v0 (#3308)

Browse Source
This commit is contained in:
chenjian
2025-08-11 13:07:04 +08:00
committed by GitHub
parent 71018fb62e
commit b88537a456
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
fastdeploy/output/token_processor.py
View File

@@ -329,8 +329,9 @@ class TokenProcessor:
if recovery_stop: if recovery_stop:
llm_logger.info(f"recovery stop signal found at task {task_id}") llm_logger.info(f"recovery stop signal found at task {task_id}")
if not recovery_stop and token_id < 0: if not recovery_stop and token_id < 0:
if task_id in self.resource_manager.to_be_rescheduled_request_id_set: if envs.ENABLE_V1_KVCACHE_SCHEDULER:
self.resource_manager.reschedule_preempt_task(task_id) if task_id in self.resource_manager.to_be_rescheduled_request_id_set:
self.resource_manager.reschedule_preempt_task(task_id)
continue continue
if task.get("prefill_chunk_info", None) is not None: if task.get("prefill_chunk_info", None) is not None: