From a7cd5a634c7a5f20f95070ba3d01c16341a0ddb6 Mon Sep 17 00:00:00 2001
From: GinHa <15201596918@163.com>
Date: Sat, 11 Jul 2026 13:16:21 +0800
Subject: [PATCH] =?UTF-8?q?celery=202=E5=B0=8F=E6=97=B6=E7=BB=93=E6=9E=9C?=
 =?UTF-8?q?=E7=95=99=E5=AD=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 video-gen-api/app/config.py           | 2 ++
 video-gen-api/app/tasks/celery_app.py | 2 ++
 2 files changed, 4 insertions(+)

diff --git a/video-gen-api/app/config.py b/video-gen-api/app/config.py
index cf044acf..7f4621f8 100644
--- a/video-gen-api/app/config.py
+++ b/video-gen-api/app/config.py
@@ -112,6 +112,8 @@ class Settings(BaseSettings):
     # ChatAPI async generation pipeline settings
     CELERY_BROKER_URL: str = ""
     CELERY_RESULT_BACKEND: str = ""
+    # Celery result backend 仅保留近期排障状态；业务恢复以数据库状态和业务日志为准。
+    CELERY_RESULT_EXPIRES_SECONDS: int = 7200
     # Celery async 兼容配置。
     # single_loop：每个 Celery 子进程一个专用 event loop，推荐线上/本地统一使用。
     # direct：旧版线程本地 loop 降级模式，建议配合 CELERY_DB_USE_NULLPOOL=true。
diff --git a/video-gen-api/app/tasks/celery_app.py b/video-gen-api/app/tasks/celery_app.py
index 58e2435f..43f210a7 100644
--- a/video-gen-api/app/tasks/celery_app.py
+++ b/video-gen-api/app/tasks/celery_app.py
@@ -77,6 +77,8 @@ if broker_url:
         task_serializer="json",
         accept_content=["json"],
         result_serializer="json",
+        result_expires=max(60, int(settings.CELERY_RESULT_EXPIRES_SECONDS or 7200)),
+        task_store_errors_even_if_ignored=True,
         timezone="Asia/Shanghai",
         enable_utc=True,
         task_soft_time_limit=600,