From 0e580ab3f7d9dcc1351cc96378e58a295cf56d61 Mon Sep 17 00:00:00 2001 From: Windpicker-owo <3431391539@qq.com> Date: Fri, 7 Nov 2025 18:52:38 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E7=AD=89=E5=BE=85=E6=9C=80=E5=A4=9A3?= =?UTF-8?q?=E7=A7=92=E4=BB=A5=E7=A1=AE=E4=BF=9D=E5=8F=96=E6=B6=88=E6=AD=A3?= =?UTF-8?q?=E5=9C=A8=E6=89=A7=E8=A1=8C=E7=9A=84=E4=BB=BB=E5=8A=A1=EF=BC=8C?= =?UTF-8?q?=E9=81=BF=E5=85=8D=E6=BD=9C=E5=9C=A8=E7=9A=84=E9=98=BB=E5=A1=9E?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/schedule/unified_scheduler.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/schedule/unified_scheduler.py b/src/schedule/unified_scheduler.py index 921102bf3..5b758c181 100644 --- a/src/schedule/unified_scheduler.py +++ b/src/schedule/unified_scheduler.py @@ -530,9 +530,9 @@ class UnifiedScheduler: if executing_task and not executing_task.done(): logger.debug(f"取消正在执行的任务: {task.task_name}") executing_task.cancel() - await executing_task + await asyncio.wait_for(executing_task, 3) self._executing_tasks.pop(schedule_id, None) - + await self._remove_task_internal(schedule_id) logger.debug(f"移除调度任务: {task.task_name}") return True