评估表达式并返回原始值 用于非布尔场景（如Map操作），返回表达式的实际计算结果。 参数： expression: 表达式字符串 context: 主求值上下文 workflow_vars:

执行任务分类用例 参数： input_data: ClassifyTaskInput 输入参数 返回： ClassifyTaskOutput 分类结果 说明： V2阶段：优先

执行单个节点并发布进度事件 参数： node_id: 节点ID 返回： 执行结果

执行多个子任务，每个在隔离环境中 参数： subtasks: 子任务列表 executors: 执行器列表（与子任务一一对应） parallel: 是否并行执行 返回：

按条件查找策略 参数： condition: 触发条件 返回： 匹配的策略列表（按优先级排序）

格式化 SSE 事件 参数： data: 事件数据 event_type: 可选的事件类型 返回： 格式化的 SSE 消息

按 ID 获取定时工作流 参数： scheduled_workflow_id: 定时工作流 ID 返回： ScheduledWorkflow 领域实体 抛出： NotFoun

获取所有日志

获取所有指标 返回： 指标字典

处理消息 参数： message: 接收到的消息 返回： 处理结果（如果有）

检查是否已注册执行器 参数： node_type: 节点类型 返回： 是否已注册

发起任务终止 参数： task_id: 任务ID reason: 终止原因 severity: 严重性 graceful: 是否优雅终止 workflow_id:

列出所有工具

记录笔记批准 参数： note: 笔记实例 approved_by: 批准者ID 返回： 创建的审计日志

记录成功解法 参数： task_type: 任务类型 task_description: 任务描述 workflow_id: 工作流 ID solution_steps: 解决步骤

保存消息到内存

保存文档

设置节点预设输出

创建span上下文管理器 参数： name: span名称 parent: 父span attributes: 初始属性

标记执行开始

更新实际输出

确保所有表存在

获取或创建数据库连接

处理 SaveRequest 事件（已由 SaveRequestOrchestrator 接管） 注意：此方法不应被直接调用，event_bus 会直接调用 orchestrator 的异步处理器。 保留此方法仅为向后兼容。 参数：

Create WorkflowAgent with mock executor for testing

添加 DAG（有向无环图）验证规则 P1-1步骤4-5: 直接委托给 RuleEngineFacade 验证工作流的节点和边结构： - 节点 ID 唯一性 - 边引用的节点存在性 - 无循环依赖

检测偏见 参数： text: 输入文本 返回： 检测结果

检测有害内容 参数： text: 输入文本 返回： 检测结果

检查阈值并生成告警 参数： workflow_id: 工作流ID 返回： 告警列表

创建工作流快照 Args: workflow_id: 工作流 ID state: 当前状态 reason: 创建原因 Returns: 快照 ID

创建工具 YAML 配置

创建测试用的 WorkflowAgent

Create workflow plan from goal (mixin method, for internal calls).

将全局目标分解为子目标 参数： global_goal: 要分解的全局目标 返回： 子目标列表 异常： DecompositionError: 分解失败时抛出

发送步骤 参数: step: 会话步骤 异常: EmitterClosedError: 如果 emitter 已关闭

为对话 Agent 创建上下文 参数： agent_id: Agent ID conversation_id: 会话 ID user_message: 用户消息 **kwargs: 其他

获取容器执行器（懒加载） 返回： 容器执行器实例

获取实验配置

获取节点输出 参数： node_id: 节点ID key: 可选，获取特定的输出key 返回： 如果指定key，返回该key的值，否则返回整个输出字典

从样本数据推断 JSON Schema 参数： data: 样本数据 返回： 推断出的 JSON Schema

初始化提示词版本管理器 参数： config: 版本配置字典（覆盖构造函数中的配置）

注入上下文 参数： target_agent: 目标 Agent context_type: 上下文类型 (warning/blocking) message: 消息 severity:

从目录加载所有工具配置 只加载 .yaml 和 .yml 扩展名的文件，跳过无效配置 参数： dir_path: 目录路径 返回： 成功加载的 ToolConfigSchema 列表

创建测试节点（固定ID以便验证）

将目标压入栈 参数： goal: 目标实体

查询日志

注册策略 参数： name: 策略名称 trigger_conditions: 触发条件列表 action: 动作 (warn/block/terminate/log) priority

注册待确认消息

执行HTTP请求. 参数: method: HTTP方法(GET/POST/PUT/DELETE等), 大小写不敏感 url: 请求URL(完整URL或相对路径) headers: 请求头(可选)

为特定节点设置失败处理策略 参数： node_id: 节点ID strategy: 失败处理策略

监督上下文（委托到 SupervisionFacade） 分析上下文数据，判断是否需要干预。 参数： context: 上下文数据 返回： 触发的 SupervisionInfo 列表

转换为文本格式（用于 LLM 上下文） 返回： 格式化的文本摘要

验证输入与参数定义对齐 检查： 1. 必需参数是否提供 2. 参数类型是否匹配 参数： node_def: 节点定义 inputs: 实际输入 返回：

等待子Agent执行 暂停当前执行，保存上下文，等待子Agent结果。 参数： subagent_id: 子Agent ID task_id: 任务ID context: 当前执行上下文（用于

基于规则从文本中提取控制流 使用简单的关键词匹配识别决策点和循环，支持中英文输入。 这是一个快速回退策略，当 LLM 分析失败时使用。 参数： text: 用户输入的目标描述 返回：

内部日志记录

暂存决策记录（P0-2 Phase 2） 用于批量提交，减少锁获取次数。 参数: record: 决策记录字典

分析任务需求与现有节点的缺口 参数： task_description: 任务描述 existing_nodes: 现有节点列表 coordinator_context: 协调者上下文（可选）

检查稳定性

统计指定 Workflow 下的 Run 数量 Args: workflow_id: Workflow ID Returns: Run 数量

创建图表生成节点定义（PYTHON 类型） 用于生成可视化图表的场景（使用 matplotlib）。 参数： name: 节点名称 chart_type: 图表类型（"line", "bar", "pie"）

创建数据分析节点定义（LLM 类型） 用于 LLM 分析数据并生成报告的场景。 参数： name: 节点名称 analysis_type: 分析类型（"summary", "insight", "recommenda

从字典格式执行工作流规划 参数： plan_dict: 规划字典 返回： 执行结果

提取 start->end 主连通子图（纯函数） 算法：BFS 正向遍历（从 start）+ BFS 反向遍历（从 end），取交集 Fail-Closed 策略： - 缺 start 或 end → 返回空集 - start/end 无路径 → 返回空集

检索相关笔记 参数： query: 查询字符串 notes: 笔记列表 limit_per_type: 每种类型的最大数量（可选） max_total: 最大总数（可选，默认 6）

生成任务提示词 Args: task_id: 任务 ID task_type: 任务类型 objective: 任务目标 context: 上下文信息

Get reasoning context for LLM calls. Returns: dict containing conversation history, goals, decision history, etc.

获取决策统计 返回： 统计字典 注意： 线程安全 - 使用锁保护 P1-1 Step 3: 优先从 statistics_ref 读取（如果提供）

获取模块 参数： name: 模块名称 version: 版本号，如果为 None 则返回最新版本 返回： 模块实例，如果不存在则返回 None

获取决策统计 (DEPRECATED - use _rule_engine_facade.get_decision_statistics) 返回： 统计字典

检查定义是否存在

健康检查

从 NodeRegistry 导入定义到统一注册中心 参数： node_registry: NodeRegistry 实例 unified_registry: 统一注册中心

向会话注入上下文（委托到 ContextInjectionManager） 参数： session_id: 会话 ID injection_type: 注入类型（InjectionType 枚举） conten

记录笔记创建 参数： note: 笔记实例 返回： 创建的审计日志

创建测试文档（固定ID + 确定性时间戳）

暂停实验

更新缓存 Args: workflow_id: 工作流 ID messages: 要缓存的消息列表 Note: - 自动更新 last_access_time

记录 API 调用

记录失败的执行 参数： error_message: 错误信息 自动禁用：当连续失败次数达到或超过 max_retries 时自动禁用

记录沙箱执行

注册事件处理器

注册子Agent类型（代理到 SubAgentOrchestrator）

Run an awaitable from synchronous code. Defensive behavior: - If no loop is running in the current thread, use `asyncio.run`. - If a loop

同步执行状态 参数： workflow_id: 工作流ID node_id: 节点ID status: 状态 outputs: 输出结果 error: 错误信息

触发钩子 参数： hook_point: 钩子点名称 context: 上下文数据（可被处理器修改） 异常： HookAbort: 处理器中止执行

触发警报

解包上下文 Args: package: 上下文包 Returns: UnpackedContext 实例

验证沙箱许可 检查： 1. 代码节点是否启用沙箱（如果 require_sandbox=True） 2. 是否包含危险导入 参数： node_def: 节点定义 require_san

计算两个状态之间的差异 参数： old_state: 旧状态 {"nodes": [...], "edges": [...]} new_state: 新状态 {"nodes": [...], "edges": [...]}

创建 Mock TaskRunner

Get next sequence number (1-based, monotonically increasing).