时间旅行

走错路了

智能体三步前做了一个错误决定，现在想回到那个岔路口试试另一条路。

开始之前

两种模式

重放和分叉——回到过去的不同方式

重放

找到目标检查点，原样重新执行

// 先运行一次图
const config = { configurable: { thread_id: "thread-1" } };
const result = await graph.invoke({}, config);

// 收集所有检查点
const states = [];
for await (const state of graph.getStateHistory(config)) {
  states.push(state);
}

// 找到 writeJoke 执行前的检查点
const beforeJoke = states.find((s) => s.next.includes("writeJoke"));

// 从那个检查点重新执行
const replayResult = await graph.invoke(null, beforeJoke.config);

📄 完整代码：09_replay.ts

重放注意点

重放不是"读缓存"——是真的重新执行

操作	重放时会怎样
LLM 调用	重新调用，可能返回不同内容（除非 temperature=0）
API 请求	重新发送请求
interrupt()	重新触发中断，等待新的 resume
随机数	生成新的随机值

分叉

修改历史状态，创建一条平行时间线

// 找到目标检查点
const beforeJoke = states.find((s) => s.next.includes("writeJoke"));

// 分叉：在那个检查点修改 topic
const forkConfig = await graph.updateState(
  beforeJoke.config,
  { topic: "chickens" },  // 修改状态
);

// 从分叉点继续执行
const forkResult = await graph.invoke(null, forkConfig);
console.log(forkResult.joke); // 关于 chickens 的笑话

📄 完整代码：09_fork.ts

指定节点

用 asNode 控制分叉后的执行起点

// 将更新视为 generateTopic 产生的
// 执行从 writeJoke（generateTopic 的后继）恢复
const forkConfig = await graph.updateState(
  beforeJoke.config,
  { topic: "chickens" },
  { asNode: "generateTopic" },
);

📄 完整代码：09_as_node.ts

中断与回溯

中断在时间旅行中总是重新触发

// 首次运行：遇到中断
await graph.invoke({ value: [] }, config);
await graph.invoke(new Command({ resume: "Alice" }), config);

// 从中断前重放 → 中断再次触发
const beforeAsk = states.filter((s) => s.next.includes("askHuman")).pop();
const replayResult = await graph.invoke(null, beforeAsk.config);
// 图再次暂停在中断处，等待新的 resume

// 从中断前分叉
const forkConfig = await graph.updateState(beforeAsk.config, { value: ["forked"] });
const forkResult = await graph.invoke(null, forkConfig);
await graph.invoke(new Command({ resume: "Bob" }), forkConfig);
// 结果: { value: ["forked", "Hello, Bob!", "Done"] }

📄 完整代码：09_interrupt_time_travel.ts

多重中断之间的分叉

图中有多个中断点时，可以从它们之间分叉

// 图结构：askName → askAge → final
// askName 和 askAge 各有一个 interrupt()

// 运行完成两个中断
await graph.invoke({ value: [] }, config);
await graph.invoke(new Command({ resume: "Alice" }), config);
await graph.invoke(new Command({ resume: "30" }), config);

// 收集检查点
const states = [];
for await (const state of graph.getStateHistory(config)) {
  states.push(state);
}

// 找到 askName 之后、askAge 之前的检查点
const between = states.filter((s) => s.next.includes("askAge")).pop();

// 在两个中断之间分叉
const forkConfig = await graph.updateState(between.config, { value: ["modified"] });
const result = await graph.invoke(null, forkConfig);
// askName 的结果保留（"name:Alice"）
// askAge 重新触发中断，等待新的回答

📄 完整代码：09_interrupt_time_travel.ts

子图与回溯

子图的时间旅行取决于它的 checkpointer 配置

模式	checkpointer	行为
继承（默认）	不单独指定	父图将整个子图视为一个超步，只能从父级时间旅行
子图独立	checkpointer: true	可以时间旅行到子图内部节点之间

// 子图使用独立的 checkpointer
const subgraph = new StateGraph(StateAnnotation)
  .addNode("stepA", stepA)  // 含 interrupt()
  .addNode("stepB", stepB)  // 含 interrupt()
  .addEdge(START, "stepA")
  .addEdge("stepA", "stepB")
  .compile({ checkpointer: true }); // 独立的检查点历史

// 获取子图的内部检查点
const parentState = await graph.getState(config, { subgraphs: true });
const subConfig = parentState.tasks[0].state.config;

// 从子图内部检查点分叉
const forkConfig = await graph.updateState(subConfig, { value: ["forked"] });
const result = await graph.invoke(null, forkConfig);
// stepB 重新执行，stepA 的结果被保留

📄 完整代码：09_subgraph_time_travel.ts

排错指南

动手练习

重放笑话生成器，分叉换主题

• 运行一次笑话链（topic = "cats"）
• 从 generateJoke 节点前重放，观察结果是否不同
• 从同一个检查点分叉，把 topic 改成 "chickens"，观察新结果

参考答案

// 1. 运行一次
const config = { configurable: { thread_id: "tt-1" } };
const result = await chain.invoke({ topic: "cats" }, config);

// 2. 收集检查点
const states = [];
for await (const s of chain.getStateHistory(config)) states.push(s);

const beforeJoke = states.find((s) => s.next.includes("generateJoke"));

// 3. 重放
const replay = await chain.invoke(null, beforeJoke.config);
console.log("重放结果:", replay.joke);

// 4. 分叉
const forkConfig = await chain.updateState(beforeJoke.config, { topic: "chickens" });
const fork = await chain.invoke(null, forkConfig);
console.log("分叉结果:", fork.joke);

本章回顾

延伸阅读