apps/worker/worker_app/tasks/_startup.py

@@ -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 任务...")