diff --git a/apps/worker/worker_app/tasks/_startup.py b/apps/worker/worker_app/tasks/_startup.py old mode 100755 new mode 100644 index 8ddfd4c11..2a66fc74d --- a/apps/worker/worker_app/tasks/_startup.py +++ b/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 任务...")