解析 prompt 支持语法： - {variable}: 从 state 中取值 - {@prompt_key}: 从 PromptManager 中取值 热更新支持：

执行单个关闭步骤，避免某个后台资源阻塞 Ctrl+C 退出。

将 messages 序列化为 JSON 字符串

Trace 上下文管理器

获取 FastAPI 应用实例（用于测试或手动配置）

Dify-compatible auth error response for workflow execution endpoints.

Build the env vars derived from a unified AgentClaw data directory.

检查断点（在节点执行前/后调用） 如果命中断点，会暂停执行并等待用户操作。 Args: node_id: 当前节点名称 state: 当前状态

Return a safety decision for workflow input content. No guard is applied when models.json does not select a safe_guard model or disables the

创建同步 Redis 客户端（用于子进程或同步上下文） Args: config: Redis 配置 Returns: redis.Redis 客户端实例 Exa

自动发现项目配置文件 查找顺序： 1. 入口脚本所在目录（sys.argv[0]） 2. 当前工作目录（CWD） 3. 指定的 base_dir

Get built-in SkillManager singleton. Built-in skills are shipped with AgentClaw package and are independent from project local ``./skills`` d

获取任务

获取全局资源管理器实例

非流式调用 LLM Args: messages: 消息列表，格式 [{"role": "user/assistant/system", "content": "..."}] response_for

组件初始化

推送 message_end 事件 Args: usage: LLM 调用的 token 使用情况（包括系统提示词） context_tokens: 会话上下文的 token 数（历史消息，不包括系统提示词）

推送输出到会话队列（供状态事件使用）

释放锁

重置单例（用于测试）

执行工作流（带追踪）

停止服务器

转换为字典格式（用于 API 返回）

转换为 JSON Schema 格式

Normalize a datetime for PostgreSQL TIMESTAMPTZ columns.

Normalize a datetime for PostgreSQL TIMESTAMP columns. Trace tables currently store naive local datetimes, so aware values coming from I

更新任务

给文本内容添加行号

写入当前进程环境，供即将启动的 server 使用

异步同步所有提示词到 Redis

Convert a base log path into a dated daily log path.

从本次请求中提取 HumanNode 恢复值，保留按钮 value 的原始类型。

Build LangGraph runtime config from AgentClaw workflow settings.

生成 thread_id，保持会话连续性

工厂方法：根据类型创建 Channel 实例

Return a path under AGENTCLAW_DATA_DIR, or an empty string when unset.

通过 snapshot 检测中断状态（兜底方案，兼容所有 LangGraph 版本）

返回固定项目名的 docker compose 基础命令

确保 Checkpointer 已初始化

确保 token 有效，仅在过期时刷新

确保追踪器已初始化（如果启用）

使用内置执行引擎（无持久化）

核心执行逻辑

获取工作流的配置文件路径

获取最后一次调用的 usage 信息

获取 Redis 缓存 key