Functions — github.com/DSGWJQ/Feagent

↓ 18 callersMethodemit_final_response

发送最终响应

src/domain/services/reliable_emitter.py:525

↓ 18 callersMethodexecute

执行工具参数： tool_name: 工具名称 params: 调用参数 timeout: 超时时间（可选）返回： ToolExecutionResult 执行结果

src/domain/services/tool_executor.py:385

↓ 18 callersMethodexecute_node

执行节点参数： node_name: 节点名称 inputs: 输入数据返回：执行结果

src/domain/services/self_describing_node.py:391

↓ 18 callersMethodexecute_node_with_result

执行节点并返回结构化结果支持自动重试和输出校验。参数： node_id: 节点ID retry_policy: 重试策略（可选） output_validator: 输出校验器（可选）

src/domain/agents/workflow_agent.py:1125

↓ 18 callersMethodexpand_children

展开子节点（从配置中的 ref 引用展开为实际 NodeDefinition）参数: registry: 子节点注册表 (ref -> NodeDefinition) depth: 当前深度（用于深度限制）返回:

src/domain/agents/node_definition.py:478

↓ 18 callersMethodfailure

创建失败结果

src/domain/services/execution_result.py:114

↓ 18 callersMethodload_builtin_modules

加载所有内置模块

src/domain/services/prompt_template_system.py:287

↓ 18 callersMethodpropagate_strategy_to_children

将策略传播给所有子节点（递归）将父节点的 error_strategy 和 resource_limits 强制传播给所有子节点。子节点的 inherited_strategy 标志会被设置为 True。策略会递归传播到所有后代节点。

src/domain/agents/node_definition.py:316

↓ 18 callersMethodput

(self, workflow_id: str, messages: list[ChatMessage])

tests/unit/domain/ports/test_memory_cache.py:61

↓ 18 callersFunctionrenderWithReactFlow

(ui: React.ReactElement)

web/src/features/workflows/components/nodes/__tests__/FileNode.test.tsx:19

↓ 18 callersFunctionrenderWithReactFlow

(ui: React.ReactElement)

web/src/features/workflows/components/nodes/__tests__/LoopNode.test.tsx:19

↓ 18 callersMethodsave

保存定时工作流参数： entity: ScheduledWorkflow 领域实体

src/infrastructure/database/repositories/scheduled_workflow_repository.py:86

↓ 18 callersMethodunsubscribe

取消订阅特定类型的事件参数： event_type: 事件类型 handler: 要移除的处理器函数返回：是否成功移除使用示例： event_

src/domain/services/event_bus.py:141

↓ 18 callersMethodvalidate_params

验证工具调用参数参数： tool_name: 工具名称 params: 调用参数返回： ValidationResult 验证结果抛出： Too

src/domain/services/tool_engine.py:697

↓ 17 callersMethodapprove_note

批准笔记将笔记从 pending_user 状态转换为 approved 状态，并记录批准者和批准时间。参数： note: 笔记实例 approved_by: 批准者ID 异常

src/domain/services/knowledge_note_lifecycle.py:76

↓ 17 callersMethodcreate_agent

创建 Agent 实例

src/domain/services/management_modules.py:560

↓ 17 callersFunctioncreate_langgraph_workflow_executor

( workflow: Workflow, *, on_event: Callable[[str, dict[str, Any]], None] | None = None, )

src/lc/workflow/langgraph_workflow_executor.py:129

↓ 17 callersMethodemit_error

发送错误步骤

src/domain/services/reliable_emitter.py:540

↓ 17 callersMethodemit_event_simple

简便方法：发出事件参数： event_type: 事件类型 data: 事件数据

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

↓ 17 callersFunctionexecute_task_with_langgraph

执行任务（使用 LangGraph 引擎）便捷函数，直接执行任务而无需先创建适配器。参数： task_name: 任务名称 task_description: 任务描述返回： str: 任务执行结果为什么

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

↓ 17 callersMethodfail

失败 Run (RUNNING → FAILED) Raises: DomainError: 当前状态不是 RUNNING

src/domain/entities/run.py:208

↓ 17 callersMethodload_recent

(self, workflow_id: str, last_n: int = 10)

tests/unit/domain/ports/test_memory_provider.py:62

↓ 17 callersMethodmerge

合并新输入到现有上下文参数： existing: 现有上下文 new_input: 新输入返回：合并后的上下文

src/domain/services/context_compressor.py:266

↓ 17 callersMethodprocess_next_save_request

处理下一个保存请求（代理到 SaveRequestOrchestrator）流程： 1. 从队列取出请求 2. 执行审核 3. 如果通过，执行写操作 4. 记录审计日志 5. 发布完成事件

src/domain/agents/coordinator_agent.py:1223

↓ 17 callersMethodrecord_execution_summary

同步记录执行总结参数： summary: ExecutionSummary 实例

src/domain/agents/coordinator_agent.py:3088

↓ 17 callersMethodsave

保存消息

src/domain/services/reliable_emitter.py:87

↓ 16 callersMethod_emit_event

发布事件

src/domain/services/tool_engine.py:1061

↓ 16 callersMethod_flush_staged_state

刷新暂存的状态更新（P0-2 Phase 2）在_state_lock保护下批量提交token使用和决策记录。性能优化: - 每轮迭代只获取一次锁 - 锁内只做纯内存更新（无await） - 减少锁竞争和上下文切

src/domain/agents/conversation_agent.py:390

↓ 16 callersMethodadd

( self, *, ids: list[str], documents: list[str], embeddings: list[list

tests/unit/infrastructure/knowledge_base/test_chroma_retriever_service.py:85

↓ 16 callersFunctionadd_fixed_move

(src: Path, dst: Path, reason: str)

scripts/organize_project_files.py:667

↓ 16 callersMethodclose

(self)

tests/unit/interfaces/api/test_workflow_executor_adapter.py:14

↓ 16 callersMethodconfigure_save_auditor

配置保存请求审核器（代理到 SaveRequestOrchestrator）参数： path_whitelist: 路径白名单（如果提供，只允许这些路径） path_blacklist: 路径黑名单 max_

src/domain/agents/coordinator_agent.py:1192

↓ 16 callersMethodcreate_node_from_definition

从 NodeDefinition 创建 Node 递归转换 NodeDefinition 为 Node，包括子节点。参数： node_def: NodeDefinition 实例返回： Node

src/domain/agents/workflow_agent.py:3240

↓ 16 callersFunctioncreate_workflow_agent

创建测试用的 WorkflowAgent

tests/unit/domain/services/test_workflow_agent_hierarchy.py:14

↓ 16 callersMethoddelete

删除用户 Args: user_id: 用户ID（UUID） Raises: EntityNotFoundError: 当用户不存在时抛出

src/domain/ports/user_repository.py:149

↓ 16 callersMethodexecute

执行用例：创建 Agent 并生成执行计划和 Workflow 业务流程： 1. 调用 Agent.create() 创建领域实体 - 验证输入（start、goal 不能为空） - 生成 ID、设置默认值

src/application/use_cases/create_agent.py:120

↓ 16 callersFunctiongetStatusColor

( status: NodeStatus | undefined, selected: boolean )

web/src/features/workflows/utils/nodeUtils.ts:12

↓ 16 callersMethodget_by_id

(self, workflow_id: str)

tests/integration/api/workflows/test_run_event_persistence.py:104

↓ 16 callersMethodget_delay

计算延迟时间参数: attempt: 尝试次数（从0开始）返回: 延迟时间（秒）

src/domain/agents/error_handling.py:359

↓ 16 callersMethodget_statistics

获取统计信息 Args: time_window_minutes: 时间窗口（分钟），None 表示全部 Returns: 统计字典

src/domain/services/dynamic_node_monitoring.py:115

↓ 16 callersMethodget_workflow_state

获取工作流状态快照 Phase 35.5: 委托给 WorkflowStateMonitor 参数： workflow_id: 工作流ID 返回：状态快照字典，如果不存在返回None

src/domain/agents/coordinator_agent.py:2311

↓ 16 callersMethodrecord

记录操作

src/domain/services/coordinator_runbook.py:753

↓ 16 callersMethodrecord_version

记录节点版本每次调用会保存节点当前状态的快照。参数： node: 节点实例 rollback_from: 如果是回滚操作，指定来源版本返回：版本记录

src/domain/services/node_version_manager.py:79

↓ 16 callersMethodrequest_save

发起保存请求（已弃用，请使用 send_save_request） .. deprecated:: Phase-P2 使用 :meth:`send_save_request` 替代。 `request_save` 将在下一主版本移除。

src/domain/agents/conversation_agent.py:576

↓ 16 callersMethodsave_snapshot

保存快照参数： context: 压缩上下文返回：快照ID

src/domain/services/context_compressor.py:642

↓ 16 callersMethodset_node_output

设置节点的输出

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

↓ 16 callersMethodstart_experiment

启动实验

src/domain/services/ab_testing_system.py:530

↓ 16 callersMethodstore

存储证据参数： data: 原始数据 source_id: 来源ID source_type: 来源类型 data_path: 数据路径（可选）返回：

src/domain/services/summary_strategy.py:121

↓ 16 callersMethodsubmit_task

提交任务执行参数： task_name: 任务名称 func: 可调用对象或协程函数 priority: 优先级（1-10，10最高） args: 位置参数 k

src/domain/services/concurrent_execution_manager.py:148

↓ 16 callersMethodvalidate_or_raise

(self, workflow: Workflow)

src/domain/services/workflow_save_validator.py:104

↓ 15 callersMethodadd_edge

添加边用于拖拽调整工作流时添加新边业务规则： - 边引用的节点必须存在参数： edge: 要添加的边抛出： DomainError: 当边引用的节点不存在时

src/domain/entities/workflow.py:231

↓ 15 callersMethodcomplete

完成发射标记 emitter 为已完成，并发送结束标记。此方法是幂等的，多次调用不会有副作用。

src/domain/services/conversation_flow_emitter.py:414

↓ 15 callersMethodcomplete_task

完成任务并打包结果 Args: output_data: 输出数据 knowledge_updates: 知识更新 Returns: ResultPackage 实例

src/domain/services/subagent_context_bridge.py:512

↓ 15 callersMethodcreate_experiment

创建实验

src/domain/services/ab_testing_system.py:440

↓ 15 callersMethodcreate_node

创建节点如果节点需要容器执行，自动创建层次结构（父节点+容器子节点）。否则创建简单的 Python 节点。参数： name: 节点名称 code: Python 代码 d

src/domain/agents/hierarchical_node_factory.py:89

↓ 15 callersMethoddisable

禁用提供商

src/domain/entities/llm_provider.py:181

↓ 15 callersMethodexecute

执行恢复动作参数: context: 恢复上下文 operation: 要重试的操作返回: 恢复结果

src/domain/agents/error_handling.py:260

↓ 15 callersMethodexecute_plan

执行工作流规划从 WorkflowPlan 创建节点和边，然后执行工作流。参数： plan: 工作流规划返回：执行结果

src/domain/agents/workflow_agent.py:2722

↓ 15 callersMethodfind_by_workflow_id

(self, workflow_id: str, limit: int = 100)

tests/unit/domain/services/test_workflow_chat_service_enhanced.py:43

↓ 15 callersMethodget

获取知识条目参数： entry_id: 条目 ID 返回：条目字典，如果不存在返回 None

src/domain/services/knowledge_manager.py:111

↓ 15 callersMethodget_metrics

获取监控指标返回： ConcurrencyMetrics 实例

src/domain/services/tool_concurrency_controller.py:535

↓ 15 callersMethodis_empty

判断 IR 是否为空返回：如果不包含任何任务、决策或循环，返回 True

src/domain/agents/control_flow_ir.py:145

↓ 15 callersMethodlog

添加执行日志 Args: message: 日志消息 level: 日志级别

src/domain/services/subagent_context_bridge.py:481

↓ 15 callersMethodon_node_start

节点开始参数： workflow_id: 工作流ID node_id: 节点ID inputs: 输入数据

src/domain/services/execution_monitor.py:470

↓ 15 callersMethodon_workflow_start

工作流开始参数： workflow_id: 工作流ID node_ids: 节点ID列表返回：执行上下文

src/domain/services/execution_monitor.py:431

↓ 15 callersMethodrelease_slot

释放执行槽位参数： slot_id: 槽位 ID 返回：执行时间（秒）

src/domain/services/tool_concurrency_controller.py:379

↓ 15 callersFunctionrenderWithProviders

( ui: ReactElement, options?: CustomRenderOptions )

web/src/test/utils.tsx:62

↓ 15 callersMethodsave

保存 ChatMessage 实体业务场景： - 用户发送消息 → 保存用户消息 - AI 回复用户 → 保存 AI 消息实现： - 如果 ID 存在，执行 merge（更新） - 如果 ID 不

src/infrastructure/database/repositories/chat_message_repository.py:36

↓ 15 callersMethodset_event_bus

设置事件总线（Step 2）参数： event_bus: EventBus 实例

src/domain/entities/session_context.py:397

↓ 15 callersMethodset_workflow_state

设置工作流状态

src/domain/services/dynamic_node_monitoring.py:342

↓ 15 callersMethodspawn

创建并启动 Agent 参数： agent_id: Agent ID agent_type: Agent 类型 config: 配置信息 resources: 资源需求

src/domain/services/resource_lifecycle.py:663

↓ 15 callersMethodstart

启动同步协议订阅相关事件并开始处理。

src/domain/services/bidirectional_sync.py:416

↓ 15 callersMethodsucceed

完成 Run (RUNNING → SUCCEEDED) - agent runs 默认终态。 Raises: DomainError: 当前状态不是 RUNNING

src/domain/entities/run.py:195

↓ 15 callersMethodvalidate_decision

验证决策按优先级遍历规则，累积错误和修正建议。异常处理策略（fail-closed）： - 规则执行异常视为验证失败 - 异常信息记录到 errors 和日志 - 统计保持一致性参数：

src/domain/services/rule_engine_facade.py:223

↓ 14 callersMethodadd_memory

添加长期记忆参数： category: 记忆类别 content: 内容 source: 来源 confidence: 置信度 metadata: 元数据

src/domain/services/knowledge_maintenance.py:567

↓ 14 callersMethodadd_sample

添加指标样本

src/domain/services/logging_metrics.py:958

↓ 14 callersMethodaudit

执行审核参数： request: SaveRequest 实例返回： AuditResult 审核结果

src/domain/services/save_request_audit.py:501

↓ 14 callersMethodemit

发送日志

src/domain/services/logging_metrics.py:553

↓ 14 callersMethodexecute

执行 Task 执行流程： 1. 记录开始事件 2. 准备输入（Task 描述 + 上下文） 3. 调用 LangChain Agent（带超时控制） 4. 处理输出 5. 记录成功事件

src/domain/services/task_executor.py:100

↓ 14 callersMethodexpand

展开节点（仅GENERIC类型）

src/domain/services/node_registry.py:304

↓ 14 callersFunctionget_model_metadata

获取模型元数据参数： provider: 提供商名称 model: 模型名称返回： ModelMetadata: 模型元数据说明： - 如果模型在注册表中，返回预定义的元数据 - 如果

src/infrastructure/lc_adapters/model_metadata.py:168

↓ 14 callersMethodget_recovery_action

获取恢复动作参数: category: 错误分类返回: 恢复动作

src/domain/agents/error_handling.py:205

↓ 14 callersMethodget_task_result

获取本地任务结果参数： task_name: 任务名称 default: 默认值返回：任务结果

src/domain/agents/subtask_executor.py:243

↓ 14 callersMethodhas_task

检查任务是否存在参数： task_name: 任务名称返回： True 如果任务存在，否则 False

src/domain/value_objects/execution_context.py:123

↓ 14 callersMethodregister

注册插件参数： plugin: 插件实例 force: 是否强制覆盖已存在的插件异常： PluginDependencyError: 依赖未满足 PluginVer

src/domain/services/extension_api.py:119

↓ 14 callersMethodrequest_subagent_spawn

请求生成子Agent（同步版本）注意:同步版本无法await事件发布，仅适用于非关键路径。在异步上下文中请使用request_subagent_spawn_async以保证关键事件顺序。参数: subagent_typ

src/domain/agents/conversation_agent.py:683

↓ 14 callersMethodsave

保存 Run（新增或更新）。单测契约：save() 需要同时支持插入与更新（外层不区分 save/update）。

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

↓ 14 callersMethodschedule

调度请求根据策略和资源配额决定是否调度请求。返回： ScheduleResult: 包含调度决策和决策依据

src/domain/services/management_modules.py:342

↓ 14 callersMethodstart_agent

启动 Agent 状态流转：CREATED/STOPPED -> INITIALIZING -> READY -> RUNNING

src/domain/services/management_modules.py:581

↓ 14 callersMethodsubscribe

订阅事件参数： callback: 事件回调函数

src/domain/services/tool_engine.py:648

↓ 13 callersMethod_normalize_sse_event

(self, *, raw_event: Mapping[str, Any], run_id: str)

src/application/services/workflow_run_execution_entry.py:101

↓ 13 callersFunction_ts

()

scripts/organize_project_files.py:56

↓ 13 callersMethodadd_entry

添加 Runbook 条目

src/domain/services/coordinator_runbook.py:907

↓ 13 callersMethodassign_variant

为用户分配变体使用确定性哈希算法确保同一用户始终分配到同一变体

src/domain/services/ab_testing_system.py:567

↓ 13 callersMethodcheck_all

执行所有健康检查返回：健康检查结果

src/domain/services/monitoring.py:381

↓ 13 callersMethodcreate

创建知识条目参数： title: 标题 content: 内容 category: 类别 tags: 标签列表（可选） metadata: 元数据（可选）

src/domain/services/knowledge_manager.py:77

↓ 13 callersMethoddecode_token

解码JWT令牌验证token签名并解码payload数据。 Args: token: JWT token字符串 Returns: Dict: 解码后的payload数据 Rais

src/infrastructure/auth/jwt_service.py:79

↓ 13 callersMethodemit_thinking

发送思考步骤参数: content: 思考内容 **metadata: 额外元数据

src/domain/services/conversation_flow_emitter.py:239

↓ 13 callersMethodenqueue

入队参数： tool_name: 工具名称 caller_id: 调用者 ID caller_type: 调用者类型 params: 调用参数 bucket:

src/domain/services/tool_concurrency_controller.py:414

↓ 13 callersMethodevaluate

评估布尔表达式参数： expression: 条件表达式字符串 context: 主求值上下文（变量字典） workflow_vars: 工作流级别变量（可选） global_vars

src/domain/services/expression_evaluator.py:131

Functions13,770 in github.com/DSGWJQ/Feagent