Functions — github.com/DSGWJQ/Feagent

↓ 6 callersMethodstart

开始执行目标

src/domain/services/goal_decomposer.py:84

↓ 6 callersMethodstart_container_execution_listening

启动容器执行事件监听订阅三种事件: - ContainerExecutionStartedEvent - ContainerExecutionCompletedEvent - ContainerLogEvent 异

src/domain/services/container_execution_monitor.py:80

↓ 6 callersMethodstart_progress_event_listener

启动进度事件监听器订阅 ExecutionProgressEvent 以接收工作流执行进度更新。

src/domain/agents/conversation_agent.py:781

↓ 6 callersMethodstart_subagent_completion_listener

启动子Agent完成事件监听器订阅 SubAgentCompletedEvent，当子Agent完成时恢复执行。

src/domain/agents/conversation_agent_state.py:514

↓ 6 callersMethodstart_test

启动 A/B 测试

src/domain/services/coordinator_runbook.py:531

↓ 6 callersMethodsupervise_workflow_execution

监督工作流执行参数： workflow_id: 工作流ID node_id: 节点ID metrics: 指标返回：监督结果

src/domain/services/supervision_strategy.py:1051

↓ 6 callersMethodsync_execution_status

同步节点执行状态参数： workflow_id: 工作流ID node_id: 节点ID status: 状态 (running, completed, failed)

src/domain/services/canvas_synchronizer.py:294

↓ 6 callersMethodterminate

终止任务参数： request: 终止请求返回：终止结果

src/domain/services/intervention/task_terminator.py:31

↓ 6 callersMethodto_dict

转换为字典

src/domain/services/dynamic_alert_rule_manager.py:80

↓ 6 callersMethodto_dict

转换为字典

src/domain/services/knowledge_manager.py:53

↓ 6 callersMethodto_dict

转换为字典（用于日志和调试）返回：配置字典（不包含实例对象）

src/domain/agents/coordinator_agent_config.py:316

↓ 6 callersMethodto_dict

(self)

src/application/services/tool_call_executor.py:45

↓ 6 callersMethodunfreeze

解冻会话（Step 3）解冻会话，允许修改会话状态。

src/domain/entities/session_context.py:477

↓ 6 callersMethodvalidate

验证数据是否符合 Schema Args: data: 待验证的字典数据 schema_version: Schema 版本 Returns: ValidationResul

src/domain/services/context_protocol.py:263

↓ 6 callersMethodvalidate

验证配置完整性检查： 1. 必选依赖是否存在 2. 配置组内部一致性 3. 配置组间依赖关系参数： strict: 是否严格校验（默认 True） - Tr

src/domain/agents/coordinator_agent_config.py:238

↓ 6 callersMethodvalidate_syntax

验证代码语法检查语法是否有效，同时检测不完整的代码模式。参数： code: 代码字符串返回： True 如果语法有效且代码完整

src/domain/services/code_repair.py:191

↓ 6 callersMethodwith_overrides

创建配置副本并覆盖部分参数支持直接覆盖顶层字段或配置组：使用示例： # 覆盖顶层字段 new_config = config.with_overrides(event_bus=new_bus)

src/domain/agents/coordinator_agent_config.py:285

↓ 6 callersMethodwrite_definition

将 YAML 定义写入文件参数： node_name: 节点名称 yaml_content: YAML 内容 overwrite: 是否覆盖已存在的文件返回：写入

src/domain/services/node_code_generator.py:773

↓ 5 callersMethod__setattr__

禁止修改属性

src/domain/services/context_bridge.py:102

↓ 5 callersMethod__setattr__

禁止修改属性

src/domain/entities/session_context.py:146

↓ 5 callersMethod_add_audit_log

添加审计日志

src/domain/services/prompt_version_manager.py:613

↓ 5 callersFunction_call_tool

(tool: Any, **kwargs: Any)

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

↓ 5 callersMethod_collect_node_inputs

收集节点的输入从上游节点的输出中收集输入。参数： node_id: 节点ID 返回：输入字典

src/domain/agents/workflow_agent.py:1297

↓ 5 callersMethod_emit_event

发布事件

src/domain/services/workflow_dependency_graph.py:574

↓ 5 callersMethod_emit_event

发送事件

src/domain/services/self_describing_node.py:386

↓ 5 callersMethod_generate_node_config

生成节点配置根据节点类型生成初始配置： - LLM: 提供默认的 model 和 prompt - PROMPT: 使用任务描述作为模板 - HTTP: 提供默认的 method 和空 url（需要用户填写） - 其

src/domain/services/agent_to_workflow_converter.py:219

↓ 5 callersMethod_handle_container_started

处理容器执行开始事件记录容器开始信息到工作流执行列表。参数: event: ContainerExecutionStartedEvent 实例

src/domain/services/container_execution_monitor.py:141

↓ 5 callersMethod_infer_node_type

推断任务的节点类型推断策略： 1. 遍历所有推断规则 2. 检查任务名称或描述是否匹配规则（正则表达式） 3. 返回第一个匹配的节点类型 4. 如果没有匹配，返回默认类型（PROMPT）参数：

src/domain/services/agent_to_workflow_converter.py:177

↓ 5 callersMethod_matches_field

检查值是否匹配 cron 字段模式参数： value: 要检查的值 pattern: Cron 模式 min_val: 最小值 max_val: 最大值返回：

src/domain/entities/scheduled_workflow.py:351

↓ 5 callersMethod_parse_sse_events

解析 SSE 事件

tests/integration/api/test_conversation_stream_api.py:153

↓ 5 callersFunction_require_coordinator

(request: Request)

src/interfaces/api/routes/coordinator_status.py:68

↓ 5 callersFunction_run_cmd

(cmd: list[str], *, cwd: Path | None = None, timeout_s: int = 5)

web/tests/e2e/scripts/collect-metrics.py:68

↓ 5 callersMethod_run_sync

同步方式运行（当事件循环已在运行时）

src/domain/agents/conversation_agent_react_core.py:177

↓ 5 callersMethod_to_entity

ORM 模型 → 领域实体时区处理: - 数据库存储 naive datetime - 领域层使用 UTC aware datetime

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

↓ 5 callersMethod_to_entity

将 ORM 模型转换为领域实体参数： model: ToolModel ORM 模型返回： Tool 领域实体

src/infrastructure/database/repositories/tool_repository.py:48

↓ 5 callersMethod_validate_cron_field

验证单个 cron 字段参数： field: 字段值 min_val: 最小值 max_val: 最大值 name: 字段名称返回： Tru

src/domain/entities/scheduled_workflow.py:232

↓ 5 callersMethodadd_error_solution

(self, error_type: str, solution: KnowledgeReference)

src/domain/ports/knowledge_retriever.py:77

↓ 5 callersMethodadd_payload_type_validation_rule

添加 payload 字段类型验证规则 P1-1步骤4-5: 直接委托给 RuleEngineFacade 参数： decision_type: 决策类型 field_types: 字段类型映射 {字段名: 类型}

src/domain/agents/coordinator_agent.py:2083

↓ 5 callersMethodadd_payload_validation_rule

添加 payload 必填字段验证规则 P1-1步骤4-5: 直接委托给 RuleEngineFacade 参数： decision_type: 决策类型 required_fields: 必填字段列表

src/domain/agents/coordinator_agent.py:2064

↓ 5 callersMethodadd_policy

添加策略参数： name: 策略名称 policy_type: 策略类型 (regex/keyword/composite) action: 动作 (warn/block/terminate)

src/domain/services/supervision_strategy.py:197

↓ 5 callersMethodanalyze_decision_chain

分析决策链路参数： decisions: 决策列表 session_id: 会话 ID 返回：触发的监督信息列表

src/domain/services/supervision_module.py:559

↓ 5 callersMethodapply_inherited_strategy

应用继承的策略（合并父节点和子节点配置）参数: parent_strategy: 父节点的错误策略 parent_resources: 父节点的资源配置

src/domain/agents/node_definition.py:501

↓ 5 callersMethodcheck

检查指标是否达标 Args: experiment_id: 实验ID variant: 变体名称 collector: 指标采集器 threshold: 门槛配置 Re

src/domain/services/ab_testing_system.py:366

↓ 5 callersFunctioncheck_rag_health

检查RAG系统健康状态

src/interfaces/api/dependencies/rag.py:159

↓ 5 callersMethodcheck_sandbox_health

检查沙箱健康状态

src/domain/services/dynamic_node_monitoring.py:616

↓ 5 callersMethodcomplete

完成发射标记 emitter 为已完成，并发送结束标记。

src/domain/services/reliable_emitter.py:560

↓ 5 callersMethodcomplete

完成请求

src/domain/services/management_modules.py:397

↓ 5 callersMethodcompress_and_store

压缩执行总结并存储使用 PowerCompressor 压缩执行总结，生成八段格式的压缩上下文，并存储到内部缓存中。参数： summary: ExecutionSummary 实例返回：

src/domain/agents/coordinator_agent.py:3162

↓ 5 callersMethodcompress_buffer_with_summary

用摘要压缩 buffer（Step 3）将旧的对话轮次压缩为摘要，只保留最近的 N 轮。参数： summary: 结构化对话摘要 keep_recent_turns: 保留最近的轮次数（默认 2）

src/domain/entities/session_context.py:532

↓ 5 callersMethodconfigure_file_security

配置文件操作安全规则参数: whitelist: 允许访问的路径白名单 blacklist: 禁止访问的路径黑名单 max_content_bytes: 内容最大字节数限制 allow

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

↓ 5 callersFunctionconvert_tool_to_unified

从 Tool 实体转换为统一定义参数： tool: Tool 实体返回：统一定义

src/domain/services/unified_definition.py:622

↓ 5 callersFunctioncreateMessage

(content: string, role: ChatMessage['role'])

web/src/hooks/useWorkflowAI.ts:28

↓ 5 callersMethodcreate_llm_adapter

创建LLM Adapter实例. 返回: LLMPort实现(Stub/Replay/OpenAI) 异常: ValueError: adapter类型未定义或配置缺失

src/interfaces/api/container.py:81

↓ 5 callersFunctioncreate_payload_from_dict

根据 action_type 创建对应的 Payload 对象 Args: action_type: 动作类型字符串 payload_dict: payload 字典 Returns: 对应的 Payload 对象 Rai

src/domain/agents/decision_payload.py:507

↓ 5 callersFunctioncreate_task_executor_agent

创建任务执行 Agent 为什么使用工厂函数？ - 统一入口：所有 Agent 都通过工厂函数创建 - 便于测试：可以在测试中 Mock - 便于管理：可以在应用启动时创建 Agent 返回： Runnable: 任务执行 Agent（简化

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

↓ 5 callersFunctioncreate_test_session_context

创建测试用的 SessionContext

tests/unit/domain/agents/test_conversation_agent_state_machine.py:22

↓ 5 callersMethoddecide_action

决定下一步行动

src/domain/agents/conversation_agent.py:103

↓ 5 callersMethoddelete

删除 Run（幂等）。

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

↓ 5 callersMethoddelete_by_workflow_id

(self, workflow_id: str)

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

↓ 5 callersMethodemit_error

触发错误事件

src/domain/services/sandbox_executor.py:502

↓ 5 callersMethodenable_auto_knowledge_retrieval

启用自动知识检索（委托）启用后，在节点失败和反思事件时会自动检索相关知识。

src/domain/agents/coordinator_agent.py:3006

↓ 5 callersMethodescalate_intervention

升级干预级别参数： current_level: 当前级别 reason: 升级原因返回：新的干预级别

src/domain/services/intervention/coordinator.py:189

↓ 5 callersMethodevaluate

评估内容是否包含敏感信息

src/domain/services/save_request_audit.py:437

↓ 5 callersMethodevaluate_compiled

执行编译后的表达式使用预编译的 AST 节点进行求值，避免重复解析开销。支持多层上下文，与 evaluate_expression 保持一致。参数： compiled_ast: 预编译的 AST Expression

src/domain/services/expression_evaluator.py:316

↓ 5 callersMethodexchange_code_for_token

将授权码换取访问令牌 GitHub OAuth流程的第一步：用户授权后获得code，后端用code换取access_token。 Args: code: GitHub回调返回的授权码 Returns:

src/infrastructure/auth/github_oauth_service.py:51

↓ 5 callersMethodexecute

执行并行分支参数： config: 并行配置 inputs: 输入数据返回：所有分支的结果

src/domain/services/advanced_executors.py:383

↓ 5 callersMethodexecute

执行知识库检索参数： config: 配置 inputs: 输入数据返回：检索结果

src/domain/services/ai_node_executors.py:104

↓ 5 callersMethodexecute

执行MCP工具调用参数： config: 配置 inputs: 输入数据返回：工具执行结果

src/domain/services/ai_node_executors.py:325

↓ 5 callersMethodexecute

执行干预动作参数： action: 统一干预请求返回：统一执行结果

src/domain/services/supervision/protocols.py:346

↓ 5 callersMethodexecute

执行子任务在隔离环境中执行，捕获所有异常。参数： executor: 执行器 task_data: 任务数据返回： SubTaskResult 执行结果（不会抛出异常）

src/domain/agents/subtask_executor.py:342

↓ 5 callersMethodexecute

处理对话消息并更新工作流参数： input_data: 输入数据返回：对话服务的修改结果（兼容：可被 API DTO 适配为 success/response/...）抛出：

src/application/use_cases/enhanced_chat_workflow.py:55

↓ 5 callersMethodexecute

执行工作流（非流式）业务流程： 1. 获取工作流（不存在抛出 NotFoundError） 2. 创建 WorkflowExecutor 3. 执行工作流 4. 返回执行结果参数：

src/application/use_cases/execute_workflow.py:82

↓ 5 callersMethodexecute_async

Mock 异步执行

src/domain/agents/container_executor.py:206

↓ 5 callersMethodexecute_run

执行 Run 执行流程： 1. 加载 Run（如果不存在，抛出 NotFoundError） 2. 加载 Tasks（按创建时间排序） 3. 启动 Run（PENDING → RUNNING） 4. 逐个执行 Task

src/domain/services/execution_engine.py:82

↓ 5 callersMethodexecute_streaming

执行工作流（流式返回）业务流程： 1. 获取工作流 2. 创建 WorkflowExecutor 3. 设置事件回调 4. 执行工作流，通过回调生成事件 5. 生成最终完成事件参数

src/application/use_cases/execute_workflow.py:119

↓ 5 callersMethodexecute_workflow

执行工作流（Legacy 兼容入口） Phase 4 重构后，推荐通过 EventBus 发布 DecisionType.EXECUTE_WORKFLOW，由 CoordinatorAgent 调度 WorkflowAgent 执行。但部分单元

src/domain/agents/conversation_agent.py:929

↓ 5 callersFunctionextract_chinese_keywords

提取中文文本中的关键词使用简单的分词和停用词过滤。参数： text: 输入文本返回：关键词列表

src/domain/services/rule_generator.py:71

↓ 5 callersMethodextract_variables

从模板中提取变量名返回：模板中使用的变量名集合

src/domain/services/prompt_template_system.py:81

↓ 5 callersMethodfail

标记目标失败

src/domain/services/goal_decomposer.py:94

↓ 5 callersMethodfilter_by_relevance

根据关键词过滤相关的消息（使用 repository）参数： keyword: 关键词 threshold: 相关性阈值（0-1） max_results: 最大返回结果数返回：

src/domain/services/workflow_chat_service_enhanced.py:191

↓ 5 callersMethodfind_bottlenecks

发现性能瓶颈参数： traces: 任务追踪列表 threshold_ms: 瓶颈阈值（毫秒）返回： Bottleneck 列表

src/domain/services/log_analysis.py:469

↓ 5 callersMethodfind_by_tag

按单个标签查找

src/domain/services/tool_engine.py:201

↓ 5 callersMethodfind_by_tags

按多个标签查找（AND 逻辑）

src/domain/services/tool_engine.py:207

↓ 5 callersMethodfind_node_by_name

按名称查找节点（包括后代）参数： name: 节点名称返回：找到的节点或 None

src/domain/agents/node_definition.py:1033

↓ 5 callersMethodforward_progress_event

转发进度事件到流式输出器参数: event: ExecutionProgressEvent 实例

src/domain/agents/conversation_agent.py:817

↓ 5 callersMethodfrom_dict

从字典创建

src/domain/services/self_describing_node.py:91

↓ 5 callersMethodfrom_file

从文件加载配置支持 JSON 和 YAML 格式。参数： file_path: 配置文件路径返回： ConfigurableRuleEngine 实例

src/domain/services/configurable_rule_engine.py:350

↓ 5 callersMethodgenerate_complete

生成完整的节点定义（YAML + 代码）参数： node_name: 节点名称 description: 描述 language: 编程语言 parameters: 参数列表

src/domain/services/node_code_generator.py:645

↓ 5 callersMethodgenerate_yaml

生成 YAML 定义参数： node_name: 节点名称 description: 描述 language: 编程语言 parameters: 参数列表 re

src/domain/services/node_code_generator.py:399

↓ 5 callersMethodget

获取场景 Args: scenario_id: 场景 ID Returns: 场景实例或 None

src/domain/services/scenario_prompt_system.py:776

↓ 5 callersMethodget_active_version

获取活跃版本对象

src/domain/services/prompt_version_manager.py:333

↓ 5 callersMethodget_audit_logs

获取审计日志

src/domain/services/ab_testing_system.py:626

↓ 5 callersMethodget_best_solution

获取最佳解法参数： task_type: 任务类型 metric_key: 用于比较的指标键返回：最佳解法或 None

src/domain/services/knowledge_maintenance.py:886

↓ 5 callersMethodget_by_id

根据 ID 获取记录

src/domain/services/tool_knowledge_store.py:305

↓ 5 callersMethodget_by_session_id

获取会话的所有消息

src/domain/services/reliable_emitter.py:147

↓ 5 callersMethodget_cached_knowledge

获取缓存的知识引用（委托）参数： workflow_id: 工作流ID 返回： KnowledgeReferences 或 None

src/domain/agents/coordinator_agent.py:2889

↓ 5 callersMethodget_connections

获取指定工作流的所有连接参数： workflow_id: 工作流ID 返回：客户端列表

src/infrastructure/websocket/canvas_sync.py:329

↓ 5 callersMethodget_context_for_conversation_agent

获取对话Agent可见的上下文

tests/unit/domain/services/test_context_compressor.py:904

↓ 5 callersMethodget_context_summary_text

获取上下文的摘要文本返回人类可读的摘要文本，适合作为对话 Agent 的上下文。参数： workflow_id: 工作流ID 返回：摘要文本，如果不存在返回None Phas

src/domain/agents/coordinator_agent.py:2646

↓ 5 callersMethodget_elapsed_time

获取已用时间（秒）

src/domain/services/validators.py:227

Functions13,770 in github.com/DSGWJQ/Feagent