Functions — github.com/DSGWJQ/Feagent

↓ 9 callersMethodrecord_duration

记录任务时长

src/domain/services/ab_testing_system.py:274

↓ 9 callersMethodrecord_sandbox_execution

记录沙箱执行时间

src/domain/services/dynamic_node_monitoring.py:630

↓ 9 callersMethodrecord_start

记录工作流开始

src/domain/services/logging_metrics.py:839

↓ 9 callersMethodregister

注册钩子处理器参数： hook_point: 钩子点名称 handler: 处理函数 priority: 优先级（越小越先执行） plugin_id: 关联的插件ID

src/domain/services/extension_api.py:416

↓ 9 callersMethodreplan_workflow

( self, goal: str, failed_node_id: str, failure_reason: str, execution

tests/integration/test_coordinator_context_integration.py:106

↓ 9 callersMethodreport_progress

报告执行进度参数： session_id: 会话ID workflow_id: 工作流ID current_node: 当前节点 progress: 进度 (0.0-1.0)

src/domain/agents/agent_channel.py:329

↓ 9 callersMethodresume

恢复实验

src/domain/services/ab_testing_system.py:129

↓ 9 callersMethodstart_feedback_listening

开始监听协调者反馈事件订阅 WorkflowAdjustmentRequestedEvent 和 NodeFailureHandledEvent，将反馈存储到 pending_feedbacks 供 ReAct 循环使用。副作用：

src/domain/agents/conversation_agent_recovery.py:117

↓ 9 callersMethodstop_agent

停止 Agent 状态流转：RUNNING/PAUSED -> STOPPING -> STOPPED

src/domain/services/management_modules.py:617

↓ 9 callersMethodsync_node_created

同步节点创建参数： workflow_id: 工作流ID node_id: 节点ID node_type: 节点类型 position: 节点位置 config

src/infrastructure/websocket/canvas_sync.py:681

↓ 9 callersMethodto_dict

序列化为字典

src/domain/agents/workflow_agent.py:189

↓ 9 callersMethodto_tool_entity

将配置转换为 Tool 实体参数： config: ToolConfigSchema 实例返回： Tool 实体实例

src/domain/services/tool_config_loader.py:245

↓ 9 callersMethodtoggle_group_collapse

切换分组的折叠状态参数： group_id: 分组ID

src/domain/agents/workflow_agent.py:2933

↓ 9 callersMethodvalidate_api_request

验证API请求安全性参数: node_id: 节点ID url: API URL method: HTTP方法 headers: 请求头 body: 请求体

src/domain/services/safety_guard/core.py:229

↓ 9 callersMethodvalidate_file_operation

验证文件操作安全性参数: node_id: 节点ID operation: 文件操作类型（read/write/append/delete/list） path: 文件路径 confi

src/domain/services/safety_guard/core.py:132

↓ 9 callersFunctionvalidate_workflow_execution_sse_event

Validate an execution SSE event against the frozen contract. Raises: ExecutionEventContractError: when the event is invalid and must not

src/application/services/workflow_event_contract.py:58

↓ 9 callersMethodwith_event_bus

设置事件总线

src/domain/agents/coordinator_agent_config.py:393

↓ 8 callersMethod_apply_modifications

应用修改到工作流参数： workflow: 原工作流 modifications: 修改指令返回： (修改后的工作流，修改数量)

src/domain/services/workflow_chat_service_enhanced.py:742

↓ 8 callersMethod_get_connection

获取数据库连接

src/infrastructure/knowledge_base/sqlite_knowledge_repository.py:33

↓ 8 callersMethod_record_execution_event_best_effort

( self, *, run_id: str, sse_event: Mapping[str, Any], execution_event_

src/application/services/workflow_run_execution_entry.py:148

↓ 8 callersMethod_tokenize

简单分词（空格分隔 + 中文按字符）处理： - 中文：按字符拆分 - 英文：按空格拆分 - 过滤空白 Args: text: 要分词的文本 Returns

src/infrastructure/memory/tfidf_compressor.py:166

↓ 8 callersFunctionadapter

适配器函数参数： task_name: 任务名称 task_description: 任务描述返回： str: 任务执行结果（最终答案）

src/infrastructure/lc_adapters/agents/task_executor_adapter.py:102

↓ 8 callersMethodadd_event

添加事件

src/domain/services/monitoring.py:228

↓ 8 callersMethodbuild_dag_validation_rule

构建 DAG（有向无环图）验证规则验证工作流的节点和边结构： - 节点 ID 唯一性 - 边引用的节点存在性 - 无循环依赖返回： Rule: 验证规则

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

↓ 8 callersMethodcalculate

计算严重程度参数： rule_violations: 规则违规列表 alignment_score: 对齐分数 (0-1, 越高越好) resource_usage_ratio: 资源使用比例 (0-1, 越

src/domain/services/intervention_strategy.py:114

↓ 8 callersMethodcan_transition

判断是否可以转换到目标状态参数： current_status: 当前状态 target_status: 目标状态返回：是否可以转换

src/domain/services/knowledge_note_lifecycle.py:212

↓ 8 callersMethodcheck_known_failure

检查已知失败参数： task_type: 任务类型 task_description: 任务描述 potential_error: 可能的错误消息返回：匹配的失败

src/domain/services/knowledge_maintenance.py:911

↓ 8 callersMethodconfigure_api_domains

配置API域名白名单规则（代理到 RuleEngineFacade.SafetyGuard） P1-1清理: 改为调用 Facade 以减少重复依赖参数: whitelist: 允许访问的域名白名单 blackli

src/domain/agents/coordinator_agent.py:987

↓ 8 callersMethodemit_step

发送步骤参数: step: 会话步骤 timeout: 超时时间（秒），仅用于 BLOCK 策略异常: EmitterClosedError: 如果 emitter 已关闭

src/domain/services/reliable_emitter.py:316

↓ 8 callersMethodenable

启用提供商

src/domain/entities/llm_provider.py:176

↓ 8 callersMethodevaluate

评估所有规则并生成告警

src/domain/services/management_modules.py:1079

↓ 8 callersFunctionevent_callback

(event_type: str, data: dict)

tests/manual/test_workflow_advanced_features.py:202

↓ 8 callersMethodexecute

执行文件处理节点参数： node: 节点实体 inputs: 输入数据（来自前驱节点） context: 执行上下文返回：操作结果

src/infrastructure/executors/file_executor.py:35

↓ 8 callersMethodexecute

执行分类参数： config: 配置 inputs: 输入数据返回：分类结果

src/domain/services/ai_node_executors.py:164

↓ 8 callersMethodexecute

执行定义参数： definition: 统一定义 params: 参数 context: 上下文返回：执行结果异常：

src/domain/services/unified_definition.py:495

↓ 8 callersMethodexecute

执行 Use Case 业务流程： 1. 获取现有工作流（不存在抛出 NotFoundError） 2. 替换节点和边（直接替换，不做增量更新） 3. 更新时间戳 4. 保存工作流为什么直接替换而不

src/application/use_cases/update_workflow_by_drag.py:81

↓ 8 callersMethodexecute_streaming

( self, *, workflow_id: str, input_data )

tests/unit/application/services/test_workflow_execution_facade_langgraph_toggle.py:62

↓ 8 callersFunctionextract_final_answer

从 LangGraph 状态提取最终答案职责： 1. 获取消息列表 2. 找到最后一条 AIMessage（通常是最终答案） 3. 返回其内容参数： state: LangGraph 返回的状态字典格式：

src/infrastructure/lc_adapters/agents/task_executor_adapter.py:35

↓ 8 callersMethodfind_all

(self)

tests/unit/domain/agents/test_coordinator_context_service.py:38

↓ 8 callersMethodfind_document_by_id

根据ID查找文档

src/domain/knowledge_base/ports/knowledge_repository.py:42

↓ 8 callersMethodfrom_yaml_file

从 YAML 文件加载 NodeDefinition 参数： file_path: YAML 文件路径返回： NodeDefinition 实例异常： ValueErro

src/domain/agents/node_definition.py:865

↓ 8 callersMethodgenerate_code

生成代码参数： node_name: 节点名称 language: 编程语言 description: 描述 parameters: 参数列表 logic_hi

src/domain/services/node_code_generator.py:475

↓ 8 callersMethodget_agent

获取 Agent 实例

src/domain/services/management_modules.py:577

↓ 8 callersMethodget_entries

获取日志条目

src/domain/services/resource_lifecycle.py:546

↓ 8 callersMethodget_execution_summary

获取执行摘要返回包含工具调用统计的摘要信息，可用于传递给 WorkflowAgent 或前端。返回：摘要字典

src/domain/services/tool_executor.py:451

↓ 8 callersMethodget_latest_snapshot

获取最新快照参数： workflow_id: 工作流ID 返回：最新的压缩上下文，不存在返回None

src/domain/services/context_compressor.py:688

↓ 8 callersFunctionget_read_file_tool

获取文件读取工具为什么使用工厂函数？ - 统一入口：所有工具都通过工厂函数获取 - 便于测试：可以在测试中 Mock - 便于管理：可以在应用启动时创建工具列表返回： Tool: 文件读取工具示例： >>> tool

src/infrastructure/lc_adapters/tools/file_tool.py:125

↓ 8 callersMethodget_save_requests_by_session

获取特定会话的保存请求（代理到 SaveRequestOrchestrator）参数： session_id: 会话 ID 返回：该会话的 SaveRequest 列表

src/domain/agents/coordinator_agent.py:1171

↓ 8 callersMethodget_usage_ratio

获取资源使用比例参数： resource: 资源类型 (tokens | iterations | time) 返回：使用比例 (0.0-1.0+)

src/domain/services/validators.py:233

↓ 8 callersMethodget_vector_store_config

获取向量存储配置

src/infrastructure/knowledge_base/rag_config_manager.py:19

↓ 8 callersMethodhas

检查键是否存在（且未过期）

src/domain/services/performance_optimizer.py:279

↓ 8 callersMethodhas_pending_save_requests

检查是否有待处理的保存请求（代理到 SaveRequestOrchestrator）返回： True 如果有待处理请求

src/domain/agents/coordinator_agent.py:1136

↓ 8 callersMethodhas_snapshot

检查是否有快照

src/domain/services/dynamic_node_monitoring.py:240

↓ 8 callersMethodincrement

增加计数器参数： name: 指标名称 value: 增量（默认1） labels: 标签字典 timestamp: 可选的时间戳

src/domain/services/monitoring.py:72

↓ 8 callersMethodinfo

信息日志

src/domain/services/subagent_context_bridge.py:214

↓ 8 callersMethodinitialize_vector_store

初始化向量存储

src/infrastructure/knowledge_base/rag_config_manager.py:112

↓ 8 callersMethodinvoke

(self, inputs: dict[str, Any])

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

↓ 8 callersMethodis_idle

检查是否空闲

src/domain/agents/conversation_agent.py:648

↓ 8 callersMethodload_template

加载模板 Args: module_name: 模块名称 version: 版本号（不指定则使用配置版本或活跃版本） Returns: str: 模板内容

src/domain/services/prompt_version_manager.py:676

↓ 8 callersMethodlog_note_submission

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

src/domain/services/knowledge_audit_log.py:176

↓ 8 callersMethodlog_state_change

记录状态变化

src/domain/services/resource_lifecycle.py:508

↓ 8 callersMethodmerge

合并两个验证结果

src/domain/services/self_describing_node_validator.py:36

↓ 8 callersMethodmerge

合并多源继承参数： sources: 继承源列表（按顺序，后者覆盖前者） child: 子节点本地定义 override: 显式覆盖配置返回：合并后的配置字典

src/domain/services/parent_node_schema.py:192

↓ 8 callersMethodok

创建成功结果

src/domain/services/self_describing_node.py:259

↓ 8 callersMethodprepare_mid_term_update

准备中期记忆更新 Args: unpacked: 解包后的结果 Returns: 中期记忆更新数据

src/domain/services/result_memory_integration.py:269

↓ 8 callersMethodprocess

处理结果包 Args: result_pkg: 结果包 Returns: ProcessingResult 实例

src/domain/services/result_memory_integration.py:651

↓ 8 callersMethodraise_for_status

模拟 httpx.Response.raise_for_status()

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

↓ 8 callersMethodrecord

记录一次测量

tests/performance/test_performance_benchmarks.py:32

↓ 8 callersMethodrecord_and_push_summary

记录总结并推送到前端参数： summary: ExecutionSummary 实例

src/domain/agents/coordinator_agent.py:3123

↓ 8 callersMethodrecord_completion

记录工作流完成

src/domain/services/logging_metrics.py:846

↓ 8 callersMethodrecord_iteration

记录一次迭代

src/domain/services/validators.py:219

↓ 8 callersMethodrecord_satisfaction

记录满意度评分

src/domain/services/ab_testing_system.py:289

↓ 8 callersMethodregister_workflow_agent

注册 WorkflowAgent 实例用于在失败处理时调用重试。参数： workflow_id: 工作流ID agent: WorkflowAgent 实例

src/domain/agents/coordinator_agent.py:2440

↓ 8 callersFunctionrenderWithProviders

(component: React.ReactElement)

web/src/features/classification/pages/__tests__/TaskClassificationPage.test.tsx:23

↓ 8 callersFunctionrenderWithQueryClient

(ui: React.ReactElement)

web/src/features/agents/components/__tests__/CreateAgentForm.test.tsx:29

↓ 8 callersMethodretrieve

检索证据参数： ref_id: 引用ID data_path: 数据路径（可选，用于检索嵌套数据）返回：原始数据或特定路径的数据，不存在返回None

src/domain/services/summary_strategy.py:161

↓ 8 callersMethodschedule

调度请求并创建上下文

src/domain/services/resource_lifecycle.py:277

↓ 8 callersMethodset_channel_bridge

设置通信桥接器参数： bridge: AgentChannelBridge 实例

src/domain/agents/coordinator_agent.py:3080

↓ 8 callersMethodset_node_output

设置节点的输出

tests/unit/domain/agents/test_workflow_conditional_multilayer_context.py:34

↓ 8 callersMethodstop

停止桥接器，取消订阅

src/domain/services/decision_execution_bridge.py:146

↓ 8 callersMethodsupervise_conversation_input

监督对话输入参数： message: 消息 session_id: 会话ID 返回：监督结果

src/domain/services/supervision_strategy.py:974

↓ 8 callersMethodsync_node_created

同步节点创建参数： workflow_id: 工作流ID node_id: 节点ID node_type: 节点类型 position: 节点位置 {x, y}

src/domain/services/canvas_synchronizer.py:194

↓ 8 callersMethodterminate_task

终止任务参数： session_id: 会话 ID reason: 终止原因 error_code: 错误代码 notify_agents: 需要通知的 Agent 列表

src/domain/agents/coordinator_agent.py:1533

↓ 8 callersMethodto_dict

转换为字典

src/infrastructure/websocket/canvas_sync.py:49

↓ 8 callersMethodto_dict

序列化为字典返回: 包含所有字段的字典（包含层次化信息）

src/domain/agents/node_definition.py:593

↓ 8 callersMethodtool_repository

获取工具仓库

src/domain/agents/coordinator_agent.py:1695

↓ 8 callersMethodunpack_from_json

从 JSON 解包 Args: json_str: JSON 字符串 Returns: UnpackedContext 实例 Raises: Context

src/domain/services/context_protocol.py:506

↓ 8 callersMethodupdate_loop_config

修改循环节点配置运行时动态更新循环节点的配置，支持根据执行反馈调整循环策略。参数： node_name: 循环节点名称 loop_type: 循环类型（for_each/map/filter/while），可选

src/domain/agents/workflow_agent.py:3765

↓ 8 callersMethodvalidate

校验输出参数： output: 输出数据返回：校验结果

src/domain/services/execution_result.py:235

↓ 8 callersMethodvalidate_input

验证输入配置参数： config: 配置字典返回：校验结果

src/domain/services/node_schema.py:504

↓ 8 callersMethodvalidate_json_format

验证 JSON 格式

src/domain/services/prompt_stability_monitor.py:539

↓ 8 callersMethodvalidate_yaml_file

校验 YAML 文件参数： file_path: YAML 文件路径返回： ValidationResult 校验结果

src/domain/services/node_yaml_validator.py:231

↓ 7 callersMethod_add_audit_log

添加审计日志

src/domain/services/ab_testing_system.py:646

↓ 7 callersMethod_emit_event

发布事件

src/domain/services/management_modules.py:538

↓ 7 callersMethod_ensure_tables

确保所有表存在

src/infrastructure/knowledge_base/sqlite_knowledge_repository.py:40

↓ 7 callersFunction_safe_str

(value: Any, default: str = "")

src/interfaces/api/routes/workflows.py:1066

↓ 7 callersMethodadd_decision

记录决策参数： decision: 决策字典

src/domain/services/context_bridge.py:168

↓ 7 callersMethodadd_event

添加执行事件业务需求： - 记录 Task 执行过程中的关键事件 - 用于审计、调试、监控参数： message: 事件消息异常： ValueError: me

src/domain/entities/task.py:346

↓ 7 callersMethodadd_goal_knowledge

(self, keyword: str, knowledge: KnowledgeReference)

src/domain/ports/knowledge_retriever.py:80

↓ 7 callersMethodadd_preference

添加用户偏好参数： user_id: 用户 ID preference_type: 偏好类型 key: 偏好键 value: 偏好值 priority: 优先级

src/domain/services/knowledge_maintenance.py:640

Functions13,770 in github.com/DSGWJQ/Feagent