fix(P0): 修复worker启动崩溃 - celery信号注册方式错误导致死循环重启

2026-07-18 20:51:08 +08:00
parent 0b60c43818
commit b4aa6ee4ee
1 changed files with 2 additions and 8 deletions
@@ -2,7 +2,7 @@

 import logging

-from worker_app.celery_app import celery_app
+from celery.signals import worker_ready
 from worker_app.db import SessionLocal

 logger = logging.getLogger(__name__)
@@ -41,13 +41,7 @@ def cleanup_orphan_tasks(timeout_minutes: int = ORPHAN_TASK_TIMEOUT_MINUTES) ->
        return 0


-@celery_app.on_after_configure.connect
-def _setup_periodic_tasks(sender, **kwargs):
-    """Celery 配置完成后，注册 worker 启动钩子。"""
-    pass
-
-
-@celery_app.on_worker_ready.connect
+@worker_ready.connect
 def _on_worker_ready(sender, **kwargs):
    """Worker 启动完成后执行 — 清理孤儿任务。"""
    logger.info("Worker 启动完成，开始清理孤儿 running 任务...")