From f4c56499b959bdda5c0e1e3d5090f13e8ca04fd5 Mon Sep 17 00:00:00 2001 From: Wenjie Zhang Date: Mon, 27 Apr 2026 18:19:39 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E4=B8=AD=E6=96=AD=E4=BB=BB=E5=8A=A1?= =?UTF-8?q?=E4=B8=8D=E5=86=8D=E5=8A=A0=E5=85=A5=E5=86=85=E5=AD=98=20Questi?= =?UTF-8?q?on:=20=E5=90=AF=E5=8A=A8=E5=8A=A0=E8=BD=BD=E4=B8=AD=E6=96=AD?= =?UTF-8?q?=E7=9A=84=E7=9F=A5=E8=AF=86=E5=BA=93=E4=BB=BB=E5=8A=A1=E7=8A=B6?= =?UTF-8?q?=E6=80=81=20Fixes=20#656?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- backend/package/yuxi/services/task_service.py | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/backend/package/yuxi/services/task_service.py b/backend/package/yuxi/services/task_service.py index de298e3f..1df7de41 100644 --- a/backend/package/yuxi/services/task_service.py +++ b/backend/package/yuxi/services/task_service.py @@ -307,11 +307,10 @@ class Tasker: task.message = "服务重启时任务未继续执行" task.updated_at = utc_isoformat() updated.append(task) - self._tasks[task.id] = task for task in updated: await self._persist_task(task) - if records: - logger.info("Loaded {} task records from storage", len(records)) + if updated: + logger.info("Marked {} interrupted tasks as failed", len(updated)) async def _persist_task(self, task: Task) -> None: data: dict[str, Any] = {