Functions — github.com/DSGWJQ/Feagent

↓ 7 callersMethodadd_rule

添加规则参数： rule: 监督规则

src/domain/services/supervision_module.py:490

↓ 7 callersMethodadd_rule

添加告警规则

src/domain/services/management_modules.py:1060

↓ 7 callersMethodadvance_stage

推进灰度阶段

src/domain/services/ab_testing_system.py:705

↓ 7 callersMethodanalyze_error

分析代码错误参数： code: 代码字符串 error: 错误实例返回：错误分析字典

src/domain/services/code_repair.py:119

↓ 7 callersMethodcheck_saturation

检查是否达到饱和阈值（Step 2）参数： threshold: 自定义阈值（可选，默认使用 saturation_threshold）返回：是否达到饱和阈值

src/domain/entities/session_context.py:405

↓ 7 callersMethodcheck_stability

检测稳定性问题参数： text: 输入文本返回：检测结果

src/domain/services/supervision/conversation.py:187

↓ 7 callersMethodcheck_thresholds

检查阈值（扩展版本）

src/domain/services/supervision_strategy.py:610

↓ 7 callersMethodcheck_workflow_feasibility

检查工作流可行性参数： session: 会话上下文 workflow_nodes: 工作流节点列表返回： WorkflowFeasibility 评估结果

src/domain/services/token_guardrail.py:214

↓ 7 callersMethodcompress_history

压缩历史消息以控制 token 数量（从数据库加载）参数： max_tokens: 最大允许的 token 数 min_messages: 最小保留消息数返回：压缩后的消息列表

src/domain/services/workflow_chat_service_enhanced.py:215

↓ 7 callersMethodconfigure_file_security

配置文件操作安全规则（代理到 RuleEngineFacade.SafetyGuard） P1-1清理: 改为调用 Facade 以减少重复依赖参数: whitelist: 允许访问的路径白名单 blacklist

src/domain/agents/coordinator_agent.py:963

↓ 7 callersMethodcreate

创建 Workflow 的工厂方法为什么使用工厂方法？ 1. 封装创建逻辑：自动生成 ID、设置默认值 2. 验证业务规则：确保 name 不为空、至少有一个节点、边引用的节点存在 3. 符合 DDD 聚合根创建模式

src/domain/entities/workflow.py:68

↓ 7 callersFunctioncreateWrapper

()

web/src/shared/hooks/__tests__/useAgents.test.tsx:61

↓ 7 callersFunctioncreate_plan_generator_chain

创建计划生成链为什么使用工厂函数？ - 延迟初始化：只在需要时创建 Chain - 便于测试：可以传入 Mock LLM - 便于管理：可以在应用启动时创建工作流程： 1. 接收输入：{"start": "...", "goal": "..."

src/infrastructure/lc_adapters/chains/plan_generator.py:49

↓ 7 callersMethodcreate_recovery_plan

创建恢复计划参数: node_id: 节点ID error: 异常 attempt: 当前尝试次数返回: 恢复计划

src/domain/agents/error_handling.py:594

↓ 7 callersMethodcreate_workflow_context

创建工作流上下文参数： workflow_id: 工作流ID session_context: 会话上下文返回：创建的工作流上下文

src/domain/services/context_bridge.py:466

↓ 7 callersMethodcreate_workflow_plan_and_publish

创建工作流规划并发布决策事件（Phase 8 新增）组合create_workflow_plan和事件发布逻辑，便于上层调用。参数： goal: 用户目标描述返回： WorkflowPlan

src/domain/agents/conversation_agent_workflow.py:269

↓ 7 callersMethoddequeue_save_request

从队列中取出最高优先级的保存请求（代理到 SaveRequestOrchestrator）返回： SaveRequest 或 None

src/domain/agents/coordinator_agent.py:1182

↓ 7 callersMethodemit_tool_result

发送工具执行结果

src/domain/services/reliable_emitter.py:502

↓ 7 callersMethodenforce_action_or_raise

( self, *, decision_type: str, decision: dict[str, Any], correlation_i

src/domain/services/coordinator_policy_chain.py:67

↓ 7 callersMethodexecute

执行数据库查询节点参数： node: 节点实体 inputs: 输入数据（来自前驱节点） context: 执行上下文返回：查询结果（列表或更新行数）

src/infrastructure/executors/database_executor.py:29

↓ 7 callersMethodexecute

执行子Agent任务参数： subagent_type: 子Agent类型（字符串） task_payload: 任务负载 context: 执行上下文 session_id: 会话I

src/domain/services/subagent_orchestrator.py:161

↓ 7 callersMethodexecute

执行保存操作参数： request: SaveRequest 实例返回： ExecutionResult 执行结果

src/domain/services/save_request_audit.py:567

↓ 7 callersMethodexecute

执行工作流生成参数： input_data: 输入参数返回：创建的工作流实体抛出： DomainError: 当验证失败或生成失败时

src/application/use_cases/generate_workflow_from_form.py:64

↓ 7 callersMethodexecute

执行导入工作流用例参数： input_data: ImportWorkflowInput 输入参数返回： ImportWorkflowOutput 输出结果抛出： Do

src/application/use_cases/import_workflow.py:120

↓ 7 callersMethodexecute_step

执行单个ReAct步骤参数: user_input: 用户输入返回: ReAct步骤

src/domain/agents/conversation_agent_react_core.py:111

↓ 7 callersMethodexecute_workflow

执行工作流参数： workflow_name: 工作流名称 inputs: 初始输入返回：执行结果

src/domain/services/workflow_dependency_graph.py:288

↓ 7 callersMethodexists

判断 Run 是否存在。

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

↓ 7 callersMethodfailure

创建失败结果

src/domain/services/self_describing_node.py:254

↓ 7 callersFunctionformat_sse_done

格式化 SSE 完成事件返回：完成消息

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

↓ 7 callersMethodfreeze

冻结会话（Step 3）冻结会话后，不允许修改会话状态。用于在压缩过程中防止并发修改。

src/domain/entities/session_context.py:469

↓ 7 callersMethodfrom_coze_json

从Coze JSON创建Workflow V2功能：支持从Coze平台导入工作流业务规则： 1. 节点类型映射：llm→LLM, http→HTTP, javascript→JAVASCRIPT等 2. 边引用验证：source和

src/domain/entities/workflow.py:267

↓ 7 callersMethodgenerate_retry_prompt

生成重试提示根据失败原因，为 LLM 生成具体的重试指导。参数： failed_response: 失败的响应 context: 执行上下文返回：重试提示字符串

src/application/services/workflow_action_parser.py:131

↓ 7 callersMethodget_canvas_state

获取画布状态参数： workflow_id: 工作流ID 返回：画布状态

src/domain/services/bidirectional_sync.py:259

↓ 7 callersMethodget_execution_summary

获取执行总结参数： workflow_id: 工作流ID 返回： ExecutionSummary 实例，如果不存在返回 None

src/domain/agents/coordinator_agent.py:3104

↓ 7 callersMethodget_node_latency

获取节点延迟参数： workflow_id: 工作流ID node_id: 节点ID 返回：延迟（秒）

src/domain/services/supervision/efficiency.py:105

↓ 7 callersMethodget_options

获取用户操作选项参数: category: 错误分类返回: 可用的操作选项列表

src/domain/agents/error_handling.py:482

↓ 7 callersMethodget_pending_save_request_count

获取待处理保存请求数量（代理到 SaveRequestOrchestrator）返回：待处理请求数量

src/domain/agents/coordinator_agent.py:1144

↓ 7 callersMethodget_priority_order

获取优先级数值（用于排序）数值越大优先级越高。参数： priority: 优先级枚举值返回：优先级数值

src/domain/services/save_request_channel.py:76

↓ 7 callersMethodget_progress

获取目标进度参数： goal_id: 目标ID 返回：完成进度 (0.0 - 1.0)

src/domain/services/goal_decomposer.py:348

↓ 7 callersMethodget_severity

获取严重级别返回：严重级别字符串

src/domain/services/save_request_receipt.py:97

↓ 7 callersMethodget_statistics

获取发送统计返回: 包含统计信息的字典

src/domain/services/reliable_emitter.py:598

↓ 7 callersMethodget_summary

获取摘要

src/domain/services/management_modules.py:1219

↓ 7 callersMethodhandle_subagent_completed

处理子Agent完成事件（sync + awaitable）兼容性要求： - 一些集成/单元测试会直接调用此方法（不 await），并期望状态立刻恢复 - EventBus wrapper 会 `await self.handle_subagent

src/domain/agents/conversation_agent_state.py:553

↓ 7 callersMethodis_child_type_allowed

检查子节点类型是否允许参数： child_type: 子节点类型返回：是否允许

src/domain/services/node_schema.py:561

↓ 7 callersMethodis_set

(value: Any)

src/domain/agents/coordinator_agent.py:710

↓ 7 callersMethodis_valid

(self, workflow_id: str)

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

↓ 7 callersMethodlist_decision_rules

列出所有决策规则返回：决策规则列表（按优先级降序排列；数值越大优先级越高）注意：线程安全 - 使用锁保护

src/domain/services/rule_engine_facade.py:174

↓ 7 callersMethodload_from_file

从文件加载场景 (自动检测 YAML/JSON) Args: file_path: 文件路径 Returns: ScenarioPrompt 实例 Raises:

src/domain/services/scenario_prompt_system.py:379

↓ 7 callersMethodlog

记录日志参数： level: 日志级别 (DEBUG/INFO/WARNING/ERROR/CRITICAL) source: 日志来源 message: 日志消息 context:

src/domain/services/unified_log_collector.py:80

↓ 7 callersMethodmark_node_running

标记节点开始运行参数： node_id: 节点ID inputs: 输入数据

src/domain/services/execution_monitor.py:247

↓ 7 callersMethodnotify_execution_started

通知执行开始参数： session_id: 会话ID workflow_id: 工作流ID

src/domain/agents/agent_channel.py:307

↓ 7 callersMethodprocess_bottleneck

处理单个瓶颈参数： bottleneck: 瓶颈对象返回：处理结果

src/domain/services/monitoring_knowledge_bridge.py:245

↓ 7 callersMethodrecord_execution_success

记录成功的执行

src/domain/entities/scheduled_workflow.py:101

↓ 7 callersMethodrecord_intervention

记录干预事件参数： intervention_type: 干预类型 reason: 原因 source: 来源 target_id: 目标ID severity

src/domain/services/supervision/coordinator.py:80

↓ 7 callersMethodrecord_to_short_term

记录到短期记忆参数： session_id: 会话 ID result: 保存结果

src/domain/services/save_request_receipt.py:207

↓ 7 callersMethodregister

注册场景 Args: scenario: 场景提示词实例

src/domain/services/scenario_prompt_system.py:761

↓ 7 callersMethodregister

注册节点定义参数： node_def: 节点定义

src/domain/services/extension_api.py:298

↓ 7 callersMethodregister_executor

注册执行器参数： executor_type: 执行器类型 executor: 执行器实例

src/domain/services/unified_definition.py:482

↓ 7 callersMethodregister_prompt_version

注册新的提示词版本参数： module_name: 模块名称 version: 版本号 (语义化版本 x.y.z) template: 模板内容 variables: 变量列表

src/domain/services/prompt_version_facade.py:115

↓ 7 callersMethodreplace_workflow_node

替换工作流节点参数： workflow_definition: 工作流定义 node_id: 原节点 ID replacement_config: 替换节点配置 reason: 替换原

src/domain/agents/coordinator_agent.py:1471

↓ 7 callersMethodreport

生成性能报告

tests/performance/test_performance_benchmarks.py:92

↓ 7 callersMethodreport_completed

报告执行完成参数： session_id: 会话ID workflow_id: 工作流ID result: 执行结果

src/domain/agents/agent_channel.py:360

↓ 7 callersMethodretrieve_relevant_chunks

( self, query: str, workflow_id: str | None = None, top_k: int = 5, fi

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

↓ 7 callersMethodrun_audit

运行审计

src/domain/services/prompt_stability_monitor.py:740

↓ 7 callersMethodsearch

简单的关键词匹配搜索

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

↓ 7 callersMethodset_workflow_state

设置工作流状态参数： workflow_id: 工作流ID nodes: 节点列表 edges: 边列表

src/infrastructure/websocket/canvas_sync.py:479

↓ 7 callersMethodshould_pass

判断日志是否应该通过过滤

src/domain/services/logging_metrics.py:497

↓ 7 callersMethodstart

启动调度器并加载已存在的任务。

src/domain/services/workflow_scheduler.py:66

↓ 7 callersMethodstart_listening

启动子Agent事件监听器订阅 SpawnSubAgentEvent 以处理子Agent生成请求。

src/domain/services/subagent_orchestrator.py:103

↓ 7 callersMethodstart_session

启动调试会话

src/domain/services/coordinator_runbook.py:646

↓ 7 callersMethodstart_simple_message_listening

开始监听简单消息事件 Phase 35.3: 委托给 MessageLogListener

src/domain/agents/coordinator_agent.py:2503

↓ 7 callersMethodstop

停止调度器。

src/domain/services/workflow_scheduler.py:78

↓ 7 callersMethodstream_after_gate

( self, *, workflow_id: str, run_id: str, input_data: Any = None,

src/application/services/workflow_run_execution_entry.py:256

↓ 7 callersMethodto_dict

转换为字典格式

src/domain/services/stream_message_formatter.py:81

↓ 7 callersMethodto_json

转换为 JSON 字符串参数： pretty: 是否美化输出（默认 True）

src/domain/services/logging_metrics.py:154

↓ 7 callersMethodto_list

转换为列表返回：引用列表

src/domain/services/knowledge_reference.py:195

↓ 7 callersFunctiontopological_sort_ids

Kahn 拓扑排序（id 级别）

src/domain/services/workflow_engine.py:29

↓ 7 callersMethodtrigger_execution

同步触发（测试/脚本使用）

src/domain/services/workflow_scheduler.py:194

↓ 7 callersMethodvalidate

校验摘要参数： summary: 摘要信息返回：校验结果

src/domain/services/summary_strategy.py:401

↓ 7 callersMethodvalidate_human_interaction

验证人机交互内容安全性（代理到 RuleEngineFacade.SafetyGuard） P1-1清理: 改为调用 Facade 以减少重复依赖参数: node_id: 节点ID prompt: 交互提示词

src/domain/agents/coordinator_agent.py:1065

↓ 7 callersMethodvalidate_input

验证输入数据参数： input_data: 输入数据字典返回：错误消息列表（空列表表示验证通过）

src/domain/agents/node_definition.py:1096

↓ 7 callersMethodvalidate_node

验证节点定义 Args: node_definition: 节点定义 Returns: 验证结果

src/domain/services/dynamic_node_monitoring.py:516

↓ 7 callersFunctionvalidate_result_schema

验证结果包是否符合 Schema Args: data: 结果包数据 Returns: (is_valid, errors) 元组

src/domain/services/result_memory_integration.py:76

↓ 7 callersMethodwrite_from_result

从结果中写入知识 Args: unpacked: 解包后的结果 tags: 额外标签 Returns: 创建的知识条目 ID 列表

src/domain/services/result_memory_integration.py:408

↓ 6 callersMethod__init__

( self, message: str, *, code: str = "run_gate_rejected", details: dic

src/domain/exceptions.py:107

↓ 6 callersMethod_build_node_inputs

构建节点输入从依赖节点的输出和全局输入中提取所需数据。

src/domain/services/workflow_dependency_graph.py:455

↓ 6 callersMethod_calculate_position

计算节点位置布局策略： - 所有节点在同一水平线上（y = NODE_Y） - 节点从左到右排列 - 每个节点间隔 NODE_SPACING 参数： index: 节点索引（0 是 STAR

src/domain/services/agent_to_workflow_converter.py:276

↓ 6 callersMethod_compressing

检查是否启用压缩

src/domain/agents/workflow_state_monitor.py:89

↓ 6 callersMethod_create_executor

创建工作流执行器

tests/integration/scheduler/test_scheduler_integration_complete.py:72

↓ 6 callersMethod_create_repositories

创建仓库实例

tests/integration/scheduler/test_scheduler_integration_complete.py:66

↓ 6 callersMethod_create_repository

创建 ScheduledWorkflow 仓库参数： session: SQLAlchemy 会话返回： SQLAlchemyScheduledWorkflowRepository 实例

tests/integration/scheduler/test_scheduled_workflow_integration.py:69

↓ 6 callersMethod_create_scheduler_service

创建调度器服务

tests/integration/scheduler/test_scheduler_integration_complete.py:76

↓ 6 callersMethod_create_tracked_task

创建被追踪的异步任务防止任务在完成前被垃圾回收（P0 Race Condition 修复）参数： coro: 协程对象返回：被追踪的 Task 对象

src/domain/agents/conversation_agent_state.py:199

↓ 6 callersMethod_expand_children_from_schema

从 schema 中展开子节点

src/domain/agents/node_definition.py:435

↓ 6 callersMethod_get_nested_value

获取嵌套值参数： data: 数据对象 path: 路径 (e.g., "user.profile.name") 返回：路径指向的值

src/infrastructure/executors/transform_executor.py:321

↓ 6 callersMethod_handle_container_log

处理容器日志事件使用有界列表记录日志，防止内存泄漏。参数: event: ContainerLogEvent 实例

src/domain/services/container_execution_monitor.py:191

↓ 6 callersMethod_log

内部日志记录（带标准 logging 兜底）

src/domain/services/subagent_orchestrator.py:70

↓ 6 callersFunction_provider_to_response

将 LLMProvider 实体转换为 Response DTO 注意：API 密钥会被掩码处理

src/interfaces/api/routes/llm_providers.py:70

↓ 6 callersMethod_publish_critical_event

发布关键事件（P0-2 Fix）关键事件需要保证： 1. 按顺序发布（使用_critical_event_lock） 2. 必须等待发布完成（await） 3. 不与_state_lock嵌套以避免死锁适用场景：

src/domain/agents/conversation_agent_state.py:219

↓ 6 callersFunction_reload_container

()

tests/test_adapter_factory.py:17

Functions13,770 in github.com/DSGWJQ/Feagent