执行中断 #

本文档中引用的文件

目录 #

  1. 简介
  2. 核心错误类型
  3. 中断配置机制
  4. 动态中断机制
  5. 执行流程控制
  6. 恢复机制
  7. 应用场景
  8. 最佳实践
  9. 总结

简介 #

LangGraphGo 的执行中断机制是一个强大的工作流控制特性，允许在图执行过程中暂停和恢复执行。这种机制支持人在回路（Human-in-the-Loop, HITL）工作流、动态决策点和交互式应用开发。通过 GraphInterrupt 错误类型和相关的配置选项，开发者可以精确控制执行流程，在关键节点暂停以等待外部输入或进行人工干预。

核心错误类型 #

GraphInterrupt 错误类型 #

GraphInterrupt 是 LangGraphGo 中表示执行中断状态的核心错误类型。它包含了中断发生时的完整上下文信息。

classDiagram
class GraphInterrupt {
+string Node
+interface State
+[]string NextNodes
+interface InterruptValue
+Error() string
}
class NodeInterrupt {
+string Node
+interface Value
+Error() string
}
GraphInterrupt --> NodeInterrupt : "包含"

图表来源

字段详解 #

字段 类型 描述
Node string 引发中断的节点名称
State interface{} 中断发生时的完整状态
NextNodes []string 如果是 InterruptAfter，包含下一个要执行的节点列表
InterruptValue interface{} 动态中断时提供的值

章节来源

NodeInterrupt 错误类型 #

NodeInterrupt 表示节点级别的中断请求，通常用于动态中断场景。

章节来源

中断配置机制 #

InterruptBefore 配置 #

InterruptBefore 允许在特定节点执行之前暂停执行，实现预检查机制。

sequenceDiagram
participant G as Graph
participant N as Node
participant C as Config
G->>G : 检查 InterruptBefore
G->>N : 准备执行节点
alt 节点在 InterruptBefore 列表中
G->>C : 返回 GraphInterrupt
C-->>G : 暂停执行
else 正常执行
G->>N : 执行节点函数
N-->>G : 返回结果
end

图表来源

使用示例 #

config := &Config{
    InterruptBefore: []string{"human_approval"},
}
res, err := runnable.InvokeWithConfig(ctx, state, config)

章节来源

InterruptAfter 配置 #

InterruptAfter 在节点执行完成后暂停，允许检查节点输出后再决定是否继续。

flowchart TD
A[开始执行] --> B[执行节点]
B --> C{检查 InterruptAfter}
C --> |命中| D[返回 GraphInterrupt]
C --> |未命中| E[继续执行]
D --> F[暂停等待恢复]
E --> G[执行下一节点]

图表来源

章节来源

动态中断机制 #

Interrupt 函数 #

Interrupt 函数是节点内部实现动态中断的核心工具，允许节点在运行时决定是否暂停执行。

flowchart TD
A[节点调用 Interrupt] --> B{检查 ResumeValue}
B --> |存在| C[返回 ResumeValue]
B --> |不存在| D[返回 NodeInterrupt 错误]
C --> E[继续执行]
D --> F[抛出中断错误]

图表来源

实现机制 #

动态中断通过以下步骤实现：

  1. 检查恢复值：首先检查上下文中是否存在 ResumeValue
  2. 条件判断：如果存在恢复值，直接返回该值
  3. 错误生成：否则返回 NodeInterrupt 错误

章节来源

动态中断示例 #

func nodeWithInterrupt(ctx context.Context, state interface{}) (interface{}, error) {
    // 节点逻辑
    name, err := graph.Interrupt(ctx, "What is your name?")
    if err != nil {
        return nil, err // 传播中断
    }
    // 使用输入继续执行
    return fmt.Sprintf("Hello, %v!", name), nil
}

章节来源

执行流程控制 #

InvokeWithConfig 方法 #

InvokeWithConfig 是处理中断的核心方法，负责协调整个执行流程。

sequenceDiagram
participant U as 用户
participant R as Runnable
participant G as Graph
participant N as Node
U->>R : InvokeWithConfig(config)
R->>G : 开始执行
loop 每个节点组
G->>G : 检查中断配置
alt 发生中断
G-->>U : 返回 GraphInterrupt
else 正常执行
par 并行执行节点
G->>N : 执行节点
N-->>G : 返回结果
end
G->>G : 处理结果和边
end
end

图表来源

中断检测流程 #

flowchart TD
A[开始节点组执行] --> B{检查 InterruptBefore}
B --> |找到匹配| C[返回 GraphInterrupt]
B --> |无匹配| D[并行执行节点]
D --> E{节点执行完成}
E --> F{检查 NodeInterrupt}
F --> |有中断| G[包装为 GraphInterrupt]
F --> |正常| H[处理结果]
G --> I[返回中断错误]
H --> J{检查 InterruptAfter}
J --> |找到匹配| K[返回 GraphInterrupt]
J --> |无匹配| L[继续执行]

图表来源

章节来源

恢复机制 #

ResumeFrom 配置 #

ResumeFrom 配置允许从特定节点重新开始执行，支持复杂的恢复场景。

classDiagram
class Config {
+[]string ResumeFrom
+interface ResumeValue
+[]string InterruptBefore
+[]string InterruptAfter
+[]CallbackHandler Callbacks
+[]string Tags
+map[string]interface Metadata
}
class ResumeMechanism {
+checkResumeFrom() bool
+prepareResumeState() interface
+restoreExecution() error
}
Config --> ResumeMechanism : "使用"

图表来源

恢复流程 #

sequenceDiagram
participant U as 用户
participant R as Runnable
participant G as Graph
U->>R : InvokeWithConfig(ResumeFrom)
R->>G : 检查 ResumeFrom 配置
G->>G : 设置当前节点为 ResumeFrom
G->>G : 使用提供的状态
loop 继续执行
G->>G : 执行剩余节点
end
G-->>U : 返回最终结果

图表来源

状态恢复策略 #

恢复类型 策略 适用场景
完整状态恢复 使用中断时的完整状态 保持执行上下文连续性
部分状态更新 只更新特定字段 优化内存使用
状态验证 检查状态完整性 确保数据一致性

章节来源

应用场景 #

人在回路 (HITL) 工作流 #

HITL 是执行中断机制最重要的应用场景之一。

sequenceDiagram
participant A as Agent
participant S as System
participant H as Human
participant R as Recovery
A->>S : 执行到审批节点
S->>H : 触发中断
H->>S : 提供审批结果
S->>R : 更新状态
R->>S : 恢复执行
S->>A : 继续工作流

图表来源

HITL 实现模式 #

  1. 预检查模式：在关键操作前暂停，等待人工确认
  2. 后检查模式：在操作完成后检查结果，决定是否继续
  3. 混合模式：结合预检查和后检查的优势

章节来源

动态决策点 #

动态中断允许节点根据运行时条件决定是否暂停。

flowchart TD
A[节点开始执行] --> B{检查条件}
B --> |满足中断条件| C[调用 Interrupt]
B --> |不满足| D[继续执行]
C --> E{首次调用?}
E --> |是| F[返回中断错误]
E --> |否| G[返回恢复值]
F --> H[等待外部输入]
G --> I[继续执行]
D --> I
H --> J[接收输入]
J --> K[恢复执行]

图表来源

章节来源

交互式应用 #

执行中断机制支持构建高度交互式的 AI 应用。

应用类型 中断策略 用户体验特点
对话系统 动态中断 实时响应用户输入
内容审核 预检查中断 人工审核关键内容
自动化流程 分阶段中断 渐进式权限授予
数据处理 后检查中断 结果验证和修正

最佳实践 #

中断设计原则 #

  1. 最小化中断频率：只在必要时中断，避免过度打断执行流程
  2. 清晰的中断原因：提供明确的中断信息，便于理解和处理
  3. 优雅的恢复机制：确保中断后能正确恢复执行
  4. 状态完整性保护：维护中断前后状态的一致性

错误处理策略 #

flowchart TD
A[捕获中断错误] --> B{错误类型}
B --> |GraphInterrupt| C[提取中断信息]
B --> |其他错误| D[常规错误处理]
C --> E{中断类型}
E --> |HITL| F[等待人工输入]
E --> |动态中断| G[处理业务逻辑]
F --> H[更新状态]
G --> I[记录日志]
H --> J[恢复执行]
I --> J
J --> K[继续流程]

性能优化建议 #

  1. 合理使用并发：在中断检测前避免不必要的并发操作
  2. 状态序列化：对于复杂状态，考虑序列化存储以减少内存占用
  3. 中断点选择：选择合适的中断点，平衡灵活性和性能

章节来源

总结 #

LangGraphGo 的执行中断机制提供了一个强大而灵活的工作流控制框架。通过 GraphInterrupt 错误类型、InterruptBefore/InterruptAfter 配置和动态中断函数 Interrupt，开发者可以构建复杂的交互式和可调试的应用程序。

核心优势 #

  1. 精确控制：支持在任意节点精确暂停执行
  2. 灵活恢复：提供多种恢复策略和配置选项
  3. 人机协作：天然支持人在回路工作流
  4. 动态决策：允许节点根据运行时条件做出中断决策

技术特点 #

执行中断机制是 LangGraphGo 架构中的重要组成部分，为构建智能、灵活和可交互的 AI 应用提供了坚实的基础。