langchain-ai/langgraphjs
1
0
Fork 0
mirror of https://github.com/langchain-ai/langgraphjs.git synced 2026-07-22 09:05:28 -04:00
Code Issues 108 Packages Projects Releases 20 Wiki Activity

Streaming updates seem to include unchanged state from subgraphs #139

New Issue
Closed
opened 2026-02-15 17:16:13 -05:00 by yindo · 1 comment
yindo commented 2026-02-15 17:16:13 -05:00
Owner
Copy Link
Copy Source

Originally created by @shaibt on GitHub (Nov 27, 2024).

I have a two tier hierarchy of graphs with some shared state between the "master" and the "subgraphs".
Each subgraph shares a partial set of state from the master in order to access the relevant current state when initiated, mutate it and return it back to the master.

The issue I'm seeing is that streaming updates seem to include state that was unchanged neither by the master or the subgraphs:

for namespace, type, chunk in supervisor_agent_graph.stream({ "messages": HumanMessage(request.message)}, config, stream_mode=["custom", "updates"], subgraphs=True):
            if type == "updates":
                [(node_name, value)] = chunk.items()
                #value includes state that was never changed
                last_update_value = value

Could it be that the "copying" of state forwards to the subgraph and back to the master is considered a state "update" even when the actual value of the state field does not change and is not updated explicitly by a node in the subgraph?

Originally created by @shaibt on GitHub (Nov 27, 2024). I have a two tier hierarchy of graphs with some shared state between the "master" and the "subgraphs". Each subgraph shares a partial set of state from the master in order to access the relevant current state when initiated, mutate it and return it back to the master. The issue I'm seeing is that streaming updates seem to include state that was unchanged neither by the master or the subgraphs: ``` for namespace, type, chunk in supervisor_agent_graph.stream({ "messages": HumanMessage(request.message)}, config, stream_mode=["custom", "updates"], subgraphs=True): if type == "updates": [(node_name, value)] = chunk.items() #value includes state that was never changed last_update_value = value ``` Could it be that the "copying" of state forwards to the subgraph and back to the master is considered a state "update" even when the actual value of the state field does not change and is not updated explicitly by a node in the subgraph?
yindo closed this issue 2026-02-15 17:16:13 -05:00
yindo commented 2026-02-15 17:16:14 -05:00
Author
Owner
Copy Link
Copy Source

@dqbd commented on GitHub (Jul 8, 2025):

Hello! Cannot seem to replicate on the following code snippet:

import { AIMessage } from "@langchain/core/messages";
import {
  Annotation,
  MessagesAnnotation,
  START,
  StateGraph,
} from "@langchain/langgraph";

const subgraph = new StateGraph(
  Annotation.Root({
    internal: Annotation<string>,
    messages: MessagesAnnotation.spec.messages,
  }),
)
  .addNode("child", () => ({
    internal: "hello",
    messages: [new AIMessage({ content: "child" })],
  }))
  .addEdge(START, "child")
  .compile();

const graph = new StateGraph(
  Annotation.Root({
    state: Annotation<string>,
    messages: MessagesAnnotation.spec.messages,
  }),
)
  .addNode("parent", () => ({
    state: "parent",
    messages: [new AIMessage({ content: "parent" })],
  }))
  .addNode("child", subgraph)
  .addEdge(START, "parent")
  .addEdge("parent", "child")
  .compile();

for await (const [namespace, type, values] of await graph.stream(
  { messages: [{ type: "human", content: "input" }] },
  { streamMode: ["custom", "updates"], subgraphs: true },
)) {
  console.log(namespace, type, values);
}

Closing for staleness. Feel free to reopen if the issue still persists.

@dqbd commented on GitHub (Jul 8, 2025): Hello! Cannot seem to replicate on the following code snippet: ```typescript import { AIMessage } from "@langchain/core/messages"; import { Annotation, MessagesAnnotation, START, StateGraph, } from "@langchain/langgraph"; const subgraph = new StateGraph( Annotation.Root({ internal: Annotation<string>, messages: MessagesAnnotation.spec.messages, }), ) .addNode("child", () => ({ internal: "hello", messages: [new AIMessage({ content: "child" })], })) .addEdge(START, "child") .compile(); const graph = new StateGraph( Annotation.Root({ state: Annotation<string>, messages: MessagesAnnotation.spec.messages, }), ) .addNode("parent", () => ({ state: "parent", messages: [new AIMessage({ content: "parent" })], })) .addNode("child", subgraph) .addEdge(START, "parent") .addEdge("parent", "child") .compile(); for await (const [namespace, type, values] of await graph.stream( { messages: [{ type: "human", content: "input" }] }, { streamMode: ["custom", "updates"], subgraphs: true }, )) { console.log(namespace, type, values); } ``` Closing for staleness. Feel free to reopen if the issue still persists.
Sign in to join this conversation.
No Branch/Tag Specified
Branches Tags
Labels
Clear labels
bug
checkpointer
docs-needed
documentation
enhancement
good first issue
good writeup
help wanted
invalid
langgraph-supervisor
open-swe-auto
platform
prebuilt
pull-request
Mirrored from GitHub Pull Request
 question
No Label
Milestone
No items
No Milestone
Projects
Clear projects
No project
Assignees
Clear assignees
yindo
No Assignees
1 Participants
Notifications
Due Date
No due date set.
Dependencies

No dependencies set.

Reference: langchain-ai/langgraphjs#139
Delete Branch "%!s()"

Deleting a branch is permanent. Although the deleted branch may continue to exist for a short time before it actually gets removed, it CANNOT be undone in most cases. Continue?