字符串转类型

Use SelectorEventLoop on Windows for psycopg async compatibility.

连接指定 Server

计算消息列表的 token 数 Args: messages: 消息列表，格式为 [{"role": "user", "content": "..."}, ...] model: 模型名称，用于选择对应的 tokenizer

创建一个待确认操作

创建调试会话

Reject obviously oversized uploads before reading file bytes.

通过 ID 查找文件

获取工具配置管理器实例

获取用户输入字段名

Return the project version from the repository VERSION file.

列出所有已连接的 Server

规范化 HumanNode 输入模式，供前端渲染。

Map docker-compose service aliases to localhost when running on host.

输出内容给用户 Args: content: 输出内容（字符串或 async iterator） node: 节点名称（可选，用于标识输出来源） save_to_context: 是否保存到 __messages__

Normalize and minimally validate a model-produced tool call before execution.

推送 message 事件（流式 token）

推送 node_started 事件

兼容旧 API - 推送输出

推送 workflow_finished 事件

Read an UploadFile in chunks and stop as soon as the limit is exceeded.

Import packaged Claw App workflow modules and register their workflows.

Render a complete project .env file from the central registry.

Run subprocess.run() in a thread to avoid Windows SelectorEventLoop limitations. This is primarily used by tool servers on Windows, where ps

验证 Token

检查新版 LangGraph 的中断标记 新版 LangGraph 不再抛出 GraphInterrupt 异常， 而是在返回结果中添加 __interrupt__ 字段

Normalize whitespace and trim noisy descriptions.

将 Workflow 编译为 LangGraph StateGraph

计算下次执行时间

Connect to browser via CDP. Auto-launches if needed (local only).

提取变量占位符

Return line numbers for first few occurrences to help disambiguate replacements.

Fire-and-forget: 在后台执行协程，不阻塞当前流程 Returns: 创建的任务对象，可用于等待完成

读取现有配置值：当前进程环境优先，其次项目 .env。占位值视为未配置。

获取 PostgreSQL 连接超时秒数。

获取 Redis 客户端（从 DatabaseManager 连接池） Returns: Redis 客户端，如果未配置或连接失败返回 None

Resolve a skill by name from project skills or builtin skills.

获取类型的字符串表示

处理调用失败

处理 GraphInterrupt 异常

处理节点级失败，返回降级模型 ID（如果需要降级）

Normalize tool arguments into a dict for signature/analysis.

解析代理返回的原始 SSE/JSON 字符串，提取实际内容

处理已解析的 ChannelMessage（内部方法，供子类直接调用）

处理恢复输入，支持普通文本和结构化审批数据

将 ScheduledJob 注册到 APScheduler

获取本地文件路径，兼容旧数据和新数据