From b4aa6ee4eeacc83c88a8db69b1d41b06d37ecd14 Mon Sep 17 00:00:00 2001 From: CI Bot Date: Sat, 18 Jul 2026 20:51:08 +0800 Subject: [PATCH] =?UTF-8?q?fix(P0):=20=E4=BF=AE=E5=A4=8Dworker=E5=90=AF?= =?UTF-8?q?=E5=8A=A8=E5=B4=A9=E6=BA=83=20-=20celery=E4=BF=A1=E5=8F=B7?= =?UTF-8?q?=E6=B3=A8=E5=86=8C=E6=96=B9=E5=BC=8F=E9=94=99=E8=AF=AF=E5=AF=BC?= =?UTF-8?q?=E8=87=B4=E6=AD=BB=E5=BE=AA=E7=8E=AF=E9=87=8D=E5=90=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- apps/worker/worker_app/tasks/_startup.py | 10 ++-------- 1 file changed, 2 insertions(+), 8 deletions(-) mode change 100755 => 100644 apps/worker/worker_app/tasks/_startup.py 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 任务...") -- 2.54.0