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: