Functions — github.com/DSGWJQ/Feagent

↓ 32 callersMethodremove

从索引移除工具

src/domain/services/tool_engine.py:179

↓ 32 callersMethodsearch

搜索工具（名称/描述模糊匹配）参数： keyword: 搜索关键词返回：匹配的工具列表

src/domain/services/tool_engine.py:583

↓ 31 callersFunction_append_error

( errors: list[dict[str, Any]], *, code: str, message: str, path: str | None = None, m

src/domain/services/workflow_save_validator.py:29

↓ 31 callersMethodcondition

(decision: dict[str, Any])

src/domain/services/safety_guard/dag_rule_builder.py:100

↓ 31 callersMethodcreate_grouped_nodes

创建分组节点（父节点包含子节点）参数： group_name: 分组名称 steps: 步骤配置列表返回：创建的父节点

src/domain/agents/workflow_agent.py:2835

↓ 31 callersMethodexecute

(self, _input_data)

tests/integration/api/workflows/test_workflow_validation_contract.py:159

↓ 31 callersMethodget_node

根据ID获取节点参数： node_id: 节点ID 返回：节点，如果不存在返回None

src/domain/agents/workflow_agent.py:928

↓ 30 callersMethodadd_error

(self, field: str, message: str, suggestion: str | None = None)

src/domain/services/parent_node_schema.py:74

↓ 30 callersFunctioncreate_workflow_agent_for_test

创建测试用的 WorkflowAgent

tests/unit/domain/agents/test_workflow_agent_enhanced.py:20

↓ 30 callersMethodget

获取任务类型配置 Args: task_type: 任务类型标识 Returns: 任务类型配置或 None

src/domain/services/scenario_prompt_system.py:712

↓ 30 callersMethodget_system_prompt

生成系统提示参数： context: 工作流执行上下文返回：系统提示字符串

src/infrastructure/lc_adapters/prompts/workflow_chat_system_prompt.py:20

↓ 30 callersMethodvalidate

验证 Schema 参数： schema: Schema 字典返回： ValidationResult 验证结果

src/domain/services/parent_node_schema.py:370

↓ 30 callersMethodvalidate

验证节点定义完整性返回：错误列表，空列表表示验证通过

src/domain/agents/node_definition.py:127

↓ 29 callersMethodadd

添加引用参数： ref: 知识引用

src/domain/services/knowledge_reference.py:187

↓ 29 callersMethodadd_decision_rule

添加决策规则参数： rule: 决策规则注意：线程安全 - 使用锁保护

src/domain/services/rule_engine_facade.py:186

↓ 29 callersMethodadd_rule

添加规则规则添加后会自动按优先级排序。参数： rule: 要添加的规则

src/domain/services/rule_engine.py:128

↓ 29 callersMethodget

按名称获取工具参数： name: 工具名称返回： Tool 实例或 None

src/domain/services/tool_engine.py:495

↓ 28 callersMethodadd_turn

添加对话轮次到短期缓冲区（Step 2）参数： buffer: ShortTermBuffer 实例说明： - 添加轮次到缓冲区 - 检测是否达到饱和阈值 - 如果

src/domain/entities/session_context.py:550

↓ 28 callersMethodclose

关闭数据库连接

src/infrastructure/knowledge_base/sqlite_knowledge_repository_old.py:43

↓ 28 callersMethodexecute

执行 HTTP 请求节点配置参数： url: 请求 URL method: 请求方法（GET, POST, PUT, DELETE, PATCH） headers: 请求头（JSON 字符串）

src/infrastructure/executors/http_executor.py:22

↓ 28 callersFunctionfake_httpx

monkeypatch httpx.AsyncClient，返回状态记录器

tests/unit/infrastructure/executors/test_http_executor.py:160

↓ 28 callersMethodget_context

获取上下文信息（同步版本）根据用户输入，查询规则库、工具库，返回相关上下文。同步版本不查询知识库。参数： user_input: 用户输入文本 workflow_id: 可选的工作流ID，用于获

src/domain/services/context/service.py:54

↓ 28 callersMethodget_statistics

获取统计信息返回：统计信息字典

src/domain/services/tool_engine.py:672

↓ 28 callersFunctionnode_factory

Node工厂函数，简化节点创建

tests/unit/infrastructure/executors/test_http_executor.py:147

↓ 28 callersMethodresolve

( self, *, run_id: str, confirm_id: str, decision: Decision, )

src/application/services/run_confirmation_store.py:80

↓ 28 callersMethodvalidate

验证决策参数： decision: 决策字典 goal: 当前目标 history: 可选的历史记录返回：验证结果

src/domain/services/validators.py:361

↓ 28 callersMethodvalidate

验证参数参数： tool: 工具定义 params: 调用参数返回： ValidationResult 验证结果

src/domain/services/tool_parameter_validator.py:198

↓ 27 callersMethodcheck_failure_rate

检查失败率并触发/清除告警

src/domain/services/dynamic_node_monitoring.py:665

↓ 27 callersMethodenqueue

入队

src/domain/services/management_modules.py:227

↓ 27 callersMethodexecute

执行工作流参数： workflow: 工作流实体 initial_input: 初始输入（传递给 Start 节点）返回：工作流执行结果（End 节点的输出）异常：

src/domain/services/workflow_executor.py:41

↓ 27 callersFunctionnode_factory

Given: Node.create 参数较多 When: 传入 config 字典 Then: 返回 LLM 节点 Node

tests/unit/infrastructure/executors/test_llm_executor.py:183

↓ 27 callersMethodsubscribe

(self, event_type: str, handler)

tests/unit/domain/services/test_context_injection.py:30

↓ 27 callersMethodvalidate_yaml_string

校验 YAML 字符串参数： yaml_content: YAML 内容字符串返回： ValidationResult 校验结果

src/domain/services/node_yaml_validator.py:190

↓ 26 callersMethodassemble

装配所有依赖按照依赖顺序构建所有组件，返回装配结果。返回： CoordinatorWiring 装配结果

src/domain/services/coordinator_bootstrap.py:530

↓ 26 callersMethodstart_context_compression

开始上下文压缩启用后，Coordinator 会在收到反思事件或节点执行事件时自动调用压缩器更新上下文快照。 Phase 35.4: 委托到 ReflectionContextManager

src/domain/agents/coordinator_agent.py:2591

↓ 26 callersMethodvalidate

验证工作流动作参数： action: 工作流动作 context: 执行上下文返回：验证结果

src/domain/services/workflow_action_validator.py:38

↓ 25 callersFunctionassert

(cond, msg, ctx)

tools/verify-seed-api.mjs:35

↓ 25 callersMethodexecute

执行代码参数： code: 要执行的代码 config: 沙箱配置 input_data: 输入数据 monitor: 执行监控器返回：执

src/domain/services/sandbox_executor.py:658

↓ 25 callersMethodexists

检查引用是否存在参数： ref_id: 引用ID 返回：是否存在

src/domain/services/summary_strategy.py:227

↓ 25 callersMethodformat

格式化 ConversationStep 为前端消息参数: step: 会话步骤返回: FrontendMessage 实例

src/domain/services/stream_message_formatter.py:126

↓ 25 callersMethodset_node_output

设置节点输出参数： node_id: 节点ID outputs: 输出数据字典

src/domain/services/context_bridge.py:198

↓ 25 callersMethodstart_reflection_listening

开始监听反思事件订阅 WorkflowReflectionCompletedEvent，记录反思结果到上下文。如果启用了上下文压缩，会同时压缩反思数据。 Phase 35.4: 委托到 ReflectionContextManager

src/domain/agents/coordinator_agent.py:2543

↓ 25 callersMethodvalidate

验证参数参数： definition: 统一定义 params: 调用参数返回：验证结果

src/domain/services/unified_definition.py:350

↓ 24 callersMethodappend

追加消息（原子双写：DB → Cache）流程： 1. 写入数据库（失败则抛异常） 2. 更新缓存（失败不影响主流程，但标记失效） Args: message: 要追加的聊天消息

src/application/services/composite_memory_service.py:91

↓ 24 callersMethodclassify

分类异常参数: error: 异常实例返回: 错误分类

src/domain/agents/error_handling.py:122

↓ 24 callersMethodexecute_workflow_with_collection_operations

执行支持集合操作的工作流 (Loop/Map/Filter) 核心逻辑： 1. 识别集合操作节点（Loop类型） 2. 对Loop节点，根据loop_type执行不同逻辑： - for_each: 遍历集合，对每个元素执行子节点

src/domain/agents/workflow_agent.py:1610

↓ 24 callersMethodparse_yaml

从 YAML 字符串解析工具配置参数： yaml_content: YAML 格式的配置字符串返回： ToolConfigSchema 实例抛出： ToolConfig

src/domain/services/tool_config_loader.py:159

↓ 24 callersMethodregister_connection

注册WebSocket连接参数： workflow_id: 工作流ID websocket: WebSocket连接对象 send_initial_state: 是否发送初始状态

src/domain/services/canvas_synchronizer.py:119

↓ 23 callersMethodadd_span

添加跨度

src/domain/services/log_analysis.py:134

↓ 23 callersMethodclear

(self)

tests/unit/domain/services/test_context_injection.py:44

↓ 23 callersFunctionexecute_task

执行任务这是一个便捷函数，封装了 Agent 的创建和调用。参数： task_name: 任务名称（简短描述） task_description: 任务详细描述（包含具体要求）返回： str: 任务执行结果

src/infrastructure/lc_adapters/agents/task_executor.py:197

↓ 23 callersMethodset_node_output

设置节点的输出

tests/unit/domain/agents/test_workflow_collection_operations.py:37

↓ 23 callersFunctionset_settings

批量设置 settings 字段（测试专用）

tests/unit/infrastructure/knowledge_base/test_rag_config_manager.py:36

↓ 23 callersMethodstore_compressed_context

存储压缩上下文直接存储已格式化的压缩上下文数据。参数： workflow_id: 工作流ID data: 压缩上下文数据字典

src/domain/agents/coordinator_agent.py:3176

↓ 22 callersMethodenable_save_request_handler

启用保存请求处理器（代理到 SaveRequestOrchestrator）启用后，Coordinator 将订阅 SaveRequest 事件并管理请求队列。

src/domain/agents/coordinator_agent.py:1094

↓ 22 callersMethodexecute_node

执行单个节点参数： node_id: 节点ID 返回：执行结果

src/domain/agents/workflow_agent.py:1055

↓ 22 callersMethodfrom_entity

从 Run 实体创建 DTO Args: run: Run 领域实体 Returns: RunResponse DTO

src/interfaces/api/dto/run_dto.py:70

↓ 22 callersMethodget_by_id

按 ID 获取 Run (不存在抛异常) Args: run_id: Run ID Returns: Run 实体 Raises: NotFoundError: 当 Run

src/domain/ports/run_repository.py:48

↓ 22 callersMethodprocess_with_intent

基于意图分类处理用户输入如果启用意图分类且置信度足够高： - 普通对话：直接生成回复，跳过 ReAct 循环 - 工作流查询：查询状态并返回 - 工作流修改/错误恢复：使用 ReAct 循环参数:

src/domain/agents/conversation_agent_intent.py:107

↓ 22 callersMethodquery

查询日志

src/domain/services/logging_metrics.py:250

↓ 22 callersMethodsend_save_request

Send save request via EventBus. 此方法是 **异步安全** 的，可在以下两种上下文安全调用： 1. **无运行循环**（普通同步代码）: 使用 asyncio.run() 发布事件 2. **有运行循环**（asyn

src/domain/agents/conversation_agent.py:454

↓ 22 callersMethodset_threshold

设置告警阈值

src/domain/services/dynamic_node_monitoring.py:657

↓ 22 callersMethodvalidate_config

验证节点配置参数： node_type: 节点类型 config: 节点配置返回： (是否有效, 错误列表)

src/domain/services/node_registry.py:742

↓ 21 callersMethodencode

(self, text: str)

src/infrastructure/knowledge_base/chroma_retriever_service.py:99

↓ 21 callersMethodget_by_id

按 ID 获取 Run (不存在抛异常) Raises: NotFoundError: 当 Run 不存在时

src/infrastructure/database/repositories/run_repository.py:189

↓ 21 callersMethodok

创建成功结果

src/domain/services/execution_result.py:98

↓ 21 callersMethodrecord_success

记录成功/失败事件

src/domain/services/ab_testing_system.py:259

↓ 21 callersMethodregister_workflow

注册工作流上下文参数： workflow_context: 工作流上下文

src/domain/services/context_bridge_enhanced.py:142

↓ 21 callersFunctionrenderWithReactFlow

(ui: React.ReactElement)

web/src/features/workflows/components/nodes/__tests__/NotificationNode.test.tsx:20

↓ 21 callersMethodsave

保存 Workflow 实体（新增或更新）实现策略： - 使用 merge()：自动判断新增或更新 - 级联保存：自动保存 Node 和 Edge - 事务控制：由调用者控制（session.commit()）参

src/infrastructure/database/repositories/workflow_repository.py:194

↓ 21 callersMethodsave

保存 Run (新增) 语义: - 创建新的 Run 记录 - Run.id 必须唯一实现要求: - 原子操作 (事务内完成) - 只 flush，不 commit

src/domain/ports/run_repository.py:35

↓ 21 callersMethodsubmit_for_approval

提交审批将笔记从 draft 状态转换为 pending_user 状态。参数： note: 笔记实例异常： LifecycleTransitionError: 如果当前状态不允许提交审批

src/domain/services/knowledge_note_lifecycle.py:61

↓ 21 callersMethodto_dict

序列化为字典返回：包含节点所有信息的字典

src/domain/services/node_registry.py:375

↓ 20 callersMethodadd_injection

添加注入参数： injection: 注入数据

src/domain/services/context_injection.py:279

↓ 20 callersMethodclear

清空索引

src/domain/services/tool_engine.py:248

↓ 20 callersFunctioncreate_executor_registry

创建执行器注册表参数： openai_api_key: OpenAI API Key anthropic_api_key: Anthropic API Key 返回：配置好的执行器注册表

src/infrastructure/executors/__init__.py:52

↓ 20 callersFunctioncreate_langgraph_task_executor

创建 LangGraph ReAct TaskExecutor 返回一个编译的 StateGraph，支持： 1. 多步推理循环 2. 条件路由（工具调用判断） 3. 工具执行和反馈 4. 最大迭代次数保护流程： ``` 输入 →

src/infrastructure/lc_adapters/agents/langgraph_task_executor.py:212

↓ 20 callersMethodexecute_workflow_with_conditions

执行支持条件分支的工作流核心逻辑： 1. 获取拓扑排序的节点执行顺序 2. 对每个节点，检查所有入边的条件 3. 只有当至少一条入边条件满足时才执行节点 4. 使用ExpressionEvaluator评估条件表达式

src/domain/agents/workflow_agent.py:1382

↓ 20 callersMethodgenerate

生成执行总结参数： workflow_result: 工作流执行结果 session_id: 会话ID coordinator_context: 协调者上下文（规则、知识、工具）返回：

src/domain/agents/execution_summary.py:351

↓ 20 callersMethodget_pending_injections

获取待处理注入参数： session_id: 会话 ID injection_point: 注入点返回：按优先级排序的注入列表（高优先级在前）

src/domain/services/context_injection.py:302

↓ 20 callersMethodhandle_intervention

处理干预参数： level: 干预级别 (InterventionLevel) context: 上下文数据返回： InterventionResult

src/domain/agents/coordinator_agent.py:1565

↓ 20 callersMethodmake_decision

做出决策

src/infrastructure/lc_adapters/workflow/react_orchestrator.py:580

↓ 20 callersMethodregister

注册定义参数： definition: 统一定义 overwrite: 是否覆盖已存在的定义异常： ValueError: 定义已存在且不允许覆盖

src/domain/services/unified_definition.py:221

↓ 20 callersMethodreload

重载工具目录检测变更（新增/修改/删除）并更新索引返回：变更信息字典：{"added": [...], "modified": [...], "removed": [...]}

src/domain/services/tool_engine.py:383

↓ 20 callersMethodstop

停止编排器取消所有订阅。

src/domain/services/agent_orchestrator.py:153

↓ 19 callersMethodadd_message

添加消息到对话历史参数： role: 消息角色 (user/assistant/system) content: 消息内容

src/domain/services/context_bridge.py:129

↓ 19 callersMethodcount

工具数量

src/domain/services/tool_engine.py:261

↓ 19 callersMethodexecute

执行 Python 代码节点参数： node: 节点实体 inputs: 输入数据（来自前驱节点） context: 执行上下文返回：代码执行后 result 变

src/infrastructure/executors/python_executor.py:71

↓ 19 callersMethodexecute

(self, tool, params, context)

tests/integration/test_tool_knowledge_integration.py:92

↓ 19 callersMethodexecute_workflow

执行整个工作流按拓扑顺序执行所有节点。返回：执行结果

src/domain/agents/workflow_agent.py:1324

↓ 19 callersMethodget_compressed_context

获取压缩后的上下文对话 Agent 可以使用此方法获取工作流的压缩上下文。参数： workflow_id: 工作流ID 返回： CompressedContext 实例，如果不存在返回None

src/domain/agents/coordinator_agent.py:2631

↓ 19 callersMethodrecord_node_creation

记录节点创建

src/domain/services/dynamic_node_monitoring.py:73

↓ 19 callersMethodrun

运行完整的 ReAct 循环参数： workflow: 要执行的工作流返回：最终的 ReAct 循环状态

src/infrastructure/lc_adapters/workflow/react_orchestrator.py:171

↓ 19 callersMethodstart

启动桥接器，订阅决策事件

src/domain/services/decision_execution_bridge.py:128

↓ 19 callersMethodvalidate_required_fields

验证必需字段必需字段： - name: 节点名称 - executor_type: 执行器类型（必须是有效类型）参数： node_def: 节点定义字典返回：

src/domain/services/self_describing_node_validator.py:205

↓ 19 callersMethodwrite

写入单条日志

src/domain/services/logging_metrics.py:242

↓ 18 callersMethodas_middleware

返回EventBus中间件函数返回：中间件函数

src/domain/agents/coordinator_agent.py:2183

↓ 18 callersMethodcount

(self)

tests/performance/test_performance_benchmarks.py:37

↓ 18 callersMethodcreate_node_with_validation

创建并验证节点参数： node_type: 节点类型 config: 节点配置返回： {success: bool, node: ValidatedNode | None, errors:

src/domain/services/node_schema.py:673

↓ 18 callersMethodcreate_rule

创建告警规则参数： name: 规则名称 rule_type: 规则类型 (threshold/pattern/rate) severity: 严重性 (info/warning/critical)

src/domain/services/dynamic_alert_rule_manager.py:113

Functions13,770 in github.com/DSGWJQ/Feagent