From bfc3883c5c5cc553822c10e89ec9c775267424d1 Mon Sep 17 00:00:00 2001
From: jingrow <support@jingrow.com>
Date: Sat, 1 Nov 2025 01:34:52 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8Ddramatiq=E9=98=9F=E5=88=97?=
 =?UTF-8?q?=E6=97=A0=E6=B3=95=E8=A7=A6=E5=8F=91=E9=92=A9=E5=AD=90=E7=9A=84?=
 =?UTF-8?q?=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 apps/jingrow/jingrow/services/queue.py | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/apps/jingrow/jingrow/services/queue.py b/apps/jingrow/jingrow/services/queue.py
index d4e39b8..7a62dfb 100644
--- a/apps/jingrow/jingrow/services/queue.py
+++ b/apps/jingrow/jingrow/services/queue.py
@@ -8,6 +8,7 @@ import dramatiq
 from dramatiq.brokers.redis import RedisBroker
 
 from jingrow.ai.pagetype.local_ai_agent.executor import NodeExecutor
+from jingrow.core.hooks.init_hooks import init_hooks
 
 logger = logging.getLogger(__name__)
 
@@ -304,6 +305,11 @@ def execute_local_scheduled_job(job_json: str) -> None:
     """Worker 执行入口：job_json 为 JSON 字符串，包含 target_type 及其参数。
     target_type: agent
     """
+    try:        
+        init_hooks(clear_cache=False)
+    except Exception as e:
+        logger.warning(f"初始化钩子系统失败: {e}")
+    
     try:
         payload = json.loads(job_json)
     except Exception as e: