跳到主要内容
LangGraph StateGraph 接收到来自多个节点的并发状态更新,针对的是不支持并发更新的状态属性。 这可能发生的情况之一是,您在图中使用了 扇出 或其他并行执行,并且您定义了一个如下所示的图:
class State(TypedDict):
    some_key: str

def node(state: State):
    return {"some_key": "some_string_value"}

def other_node(state: State):
    return {"some_key": "some_string_value"}


builder = StateGraph(State)
builder.add_node(node)
builder.add_node(other_node)
builder.add_edge(START, "node")
builder.add_edge(START, "other_node")
graph = builder.compile()
如果上述图中的一个节点返回 { "some_key": "some_string_value" },这将用 "some_string_value" 覆盖 "some_key" 的状态值。然而,如果在单个步骤中的扇出等多个节点返回 "some_key" 的值,图将抛出此错误,因为如何更新内部状态存在不确定性。 为了解决这个问题,您可以定义一个 reducer 来组合多个值:
import operator
from typing import Annotated

class State(TypedDict):
    # The operator.add reducer fn makes this append-only  #
    some_key: Annotated[list, operator.add]  
这将允许您定义处理从并行执行的多个节点返回的相同键的逻辑。

故障排除

以下方法可能有助于解决此错误:
  • 如果您的图并行执行节点,请确保您已定义了带有 reducer 的相关状态键。

以编程方式连接这些文档到 Claude、VSCode 等,通过 MCP 获取实时答案。
© . This site is unofficial and not affiliated with LangChain, Inc.