fix(terminate): 解决插件卸载/重载时因 schedule_jobs(None) 调用导致的 NoneType 报错,完善资源清理流程。

This commit is contained in:
SXP-Simon
2026-03-12 18:43:47 +08:00
parent b3e11a8cf7
commit 2e5ef3eba3
2 changed files with 7 additions and 1 deletions
+1 -1
View File
@@ -241,7 +241,7 @@ class GroupDailyAnalysis(Star):
# 2. 停止各个组件
if self.auto_scheduler:
logger.info("正在停止自动调度器...")
self.auto_scheduler.schedule_jobs(None) # type: ignore
self.auto_scheduler.unschedule_jobs(self.context)
if self.retry_manager:
await self.retry_manager.stop()
@@ -269,7 +269,13 @@ class AutoScheduler:
def unschedule_jobs(self, context):
"""取消定时任务"""
if not context or not hasattr(context, "cron_manager") or not context.cron_manager:
return
scheduler = context.cron_manager.scheduler
if not scheduler:
return
for job_id in self.scheduler_job_ids:
try:
if scheduler.get_job(job_id):