Set store & stream writer

This PR fixes the return type annotation of the `update` method from
`None` to `bool`, as the method returns a boolean value indicating
whether self.values has changed

Co-authored-by: kakaogames <kakaogames@Justin-MacBook-Pro.local>

docs/_scripts/third_party_page/packages.yml

@@ -36,3 +36,6 @@ packages:
   - name: "langgraph-reflection"
     repo: "langchain-ai/langgraph-reflection"
     description: "LangGraph agent that runs a reflection step."
+  - name: "langgraph-codeact"
+    repo: "langchain-ai/langgraph-codeact"
+    description: "LangGraph implementation of CodeAct agent that generates and executes code instead of tool calling."

docs/docs/adopters.md

@@ -10,14 +10,17 @@ This list of companies using LangGraph and their success stories is compiled fro
 | [Athena Intelligence](https://www.athenaintel.com/) | Software & Technology (GenAI Native) | Research & summarization | [Case study, 2024](https://blog.langchain.dev/customers-athena-intelligence/) |
 | [Captide](https://www.captide.co/) | Software & Technology (GenAI Native) | Data extraction | [Case study, 2025](https://blog.langchain.dev/how-captide-is-redefining-equity-research-with-agentic-workflows-built-on-langgraph-and-langsmith/) |
 | [Cisco Outshift](https://outshift.cisco.com/) | Software & Technology | DevOps | [Blog post, 2025](https://outshift.cisco.com/blog/build-react-agent-application-for-devops-tasks-using-rest-apis) |
+| [C.H. Robinson](https://www.chrobinson.com/en-us/) | Logistics | Automation | [Case study, 2025](https://blog.langchain.dev/customers-chrobinson/) |
 | [Elastic](https://www.elastic.co/) | Software & Technology | Copilot for domain-specific task | [Blog post, 2025](https://www.elastic.co/blog/elastic-security-generative-ai-features) |
 | [GitLab](https://about.gitlab.com/) | Software & Technology | Code generation | [Duo workflow docs](https://handbook.gitlab.com/handbook/engineering/architecture/design-documents/duo_workflow/) |
+| [Inconvo](https://inconvo.ai/?ref=blog.langchain.dev) | Software & Technology | Code generation | [Case study, 2025](https://blog.langchain.dev/customers-inconvo/) |
 | [Infor](https://infor.com/) | Software & Technology | GenAI embedded product experiences; customer support; copilot | [Case study, 2025](https://blog.langchain.dev/customers-infor/) |
 | [Klarna](https://www.klarna.com/) | Fintech | Copilot for domain-specific task | [Case study, 2025](https://blog.langchain.dev/customers-klarna/) |
 | [Komodo Health](https://www.komodohealth.com/) | Healthcare | Copilot for domain-specific task | [Blog post](https://www.komodohealth.com/perspectives/new-gen-ai-assistant-empowers-the-enterprise/) |
 | [LinkedIn](https://www.linkedin.com/) | Social Media | Code generation; Search & discovery | [Blog post, 2025](https://www.linkedin.com/blog/engineering/ai/practical-text-to-sql-for-data-analytics); [Blog post, 2024](https://www.linkedin.com/blog/engineering/generative-ai/behind-the-platform-the-journey-to-create-the-linkedin-genai-application-tech-stack) |
 | [Minimal](https://gominimal.ai/) | E-commerce | Customer support | [Case study, 2025](https://blog.langchain.dev/how-minimal-built-a-multi-agent-customer-support-system-with-langgraph-langsmith/) |
 | [OpenRecovery](https://www.openrecovery.com/) | Healthcare | Copilot for domain-specific task | [Case study, 2024](https://blog.langchain.dev/customers-openrecovery/) |
+| [Qodo](https://www.qodo.ai/) | Software & Technology (GenAI Native) | Code generation | [Blog post, 2025](https://www.qodo.ai/blog/why-we-chose-langgraph-to-build-our-coding-agent/) |
 | [Rakuten](https://www.rakuten.com/) | E-commerce / Fintech | Copilot for domain-specific task | [Blog post, 2025](https://rakuten.today/blog/from-ai-hype-to-real-world-tools-rakuten-teams-up-with-langchain.html) |
 | [Replit](https://replit.com/) | Software & Technology | Code generation | [Blog post, 2024](https://blog.langchain.dev/customers-replit/); [Breakout agent story, 2024](https://www.langchain.com/breakoutagents/replit); [Fireside chat video, 2024](https://www.youtube.com/watch?v=ViykMqljjxU) |
 | [Rexera](https://www.rexera.com/) | Real Estate (GenAI Native) | Copilot for domain-specific task | [Case study, 2024](https://blog.langchain.dev/customers-rexera/) |
@@ -25,3 +28,4 @@ This list of companies using LangGraph and their success stories is compiled fro
 | [Uber](https://www.uber.com/) | Transportation | Developer productivity; Code generation | [Presentation, 2024](https://dpe.org/sessions/ty-smith-adam-huda/this-year-in-ubers-ai-driven-developer-productivity-revolution/); [Video, 2024](https://www.youtube.com/watch?v=8rkA5vWUE4Y) |
 | [Unify](https://www.unifygtm.com/) | Software & Technology (GenAI Native) | Copilot for domain-specific task | [Blog post, 2024](https://blog.langchain.dev/unify-launches-agents-for-account-qualification-using-langgraph-and-langsmith/) |
 | [Vizient](https://www.vizientinc.com/) | Healthcare | Copilot for domain-specific task | [Case study, 2025](https://blog.langchain.dev/p/3d2cd58c-13a5-4df9-bd84-7d54ed0ed82c/) |
+| [Vodafone](https://www.vodafone.com/) | Telecommunications | Code generation; internal search | [Case study, 2025](https://blog.langchain.dev/customers-vodafone/) |

docs/docs/stylesheets/version_admonitions.css

@@ -0,0 +1,38 @@
+:root {
+  --md-admonition-icon--version-added: url('data:image/svg+xml;charset=utf-8,<svg xmlns="http://www.w3.org/2000/svg" viewBox="0 0 24 24"><path d="M19 2H5c-1.1 0-2 .9-2 2v14c0 1.1.9 2 2 2h4l3 3 3-3h4c1.1 0 2-.9 2-2V4c0-1.1-.9-2-2-2m0 16h-4.2l-.8.8-2 2-2-2-.8-.8H5V4h14z"/><path d="M11 15h2v2h-2v-2m0-10h2v8h-2V5"/></svg>');
+  --md-admonition-icon--version-changed: url('data:image/svg+xml;charset=utf-8,<svg xmlns="http://www.w3.org/2000/svg" viewBox="0 0 24 24"><path d="M19 2H5c-1.1 0-2 .9-2 2v14c0 1.1.9 2 2 2h4l3 3 3-3h4c1.1 0 2-.9 2-2V4c0-1.1-.9-2-2-2m0 16h-4.2l-.8.8-2 2-2-2-.8-.8H5V4h14z"/><path d="M15 11h-2V9h-2v2H9v2h2v2h2v-2h2v-2Z"/></svg>');
+}
+
+.md-typeset .admonition.version-added,
+.md-typeset details.version-added {
+  border-color: rgb(0, 191, 165);
+}
+
+.md-typeset .version-added > .admonition-title,
+.md-typeset .version-added > summary {
+  background-color: rgba(0, 191, 165, 0.1);
+}
+
+.md-typeset .version-added > .admonition-title::before,
+.md-typeset .version-added > summary::before {
+  background-color: rgb(0, 191, 165);
+  -webkit-mask-image: var(--md-admonition-icon--version-added);
+          mask-image: var(--md-admonition-icon--version-added);
+}
+
+.md-typeset .admonition.version-changed,
+.md-typeset details.version-changed {
+  border-color: rgb(100, 221, 23);
+}
+
+.md-typeset .version-changed > .admonition-title,
+.md-typeset .version-changed > summary {
+  background-color: rgba(100, 221, 23, 0.1);
+}
+
+.md-typeset .version-changed > .admonition-title::before,
+.md-typeset .version-changed > summary::before {
+  background-color: rgb(100, 221, 23);
+  -webkit-mask-image: var(--md-admonition-icon--version-changed);
+          mask-image: var(--md-admonition-icon--version-changed);
+} 

docs/mkdocs.yml

@@ -503,3 +503,5 @@ validation:
   not_found: info
 copyright: >
   Copyright &copy; 2025 LangChain, Inc | <a href="#__consent">Consent Preferences</a>
+extra_css:
+  - stylesheets/version_admonitions.css

libs/langgraph/bench/__main__.py

@@ -252,27 +252,15 @@ benchmarks = (
         },
     ),
     (
-        "sequential_20",
-        create_sequential(20).compile(),
-        create_sequential(20).compile(),
+        "sequential_10",
+        create_sequential(10).compile(),
+        create_sequential(10).compile(),
         {"messages": []},  # Empty list of messages
     ),
     (
-        "sequential_50",
-        create_sequential(50).compile(),
-        create_sequential(50).compile(),
-        {"messages": []},  # Empty list of messages
-    ),
-    (
-        "sequential_100",
-        create_sequential(100).compile(),
-        create_sequential(100).compile(),
-        {"messages": []},  # Empty list of messages
-    ),
-    (
-        "sequential_200",
-        create_sequential(200).compile(),
-        create_sequential(200).compile(),
+        "sequential_1000",
+        create_sequential(1000).compile(),
+        create_sequential(1000).compile(),
         {"messages": []},  # Empty list of messages
     ),
     (
@@ -383,8 +371,17 @@ for name, agraph, graph, input in benchmarks:
         r.bench_func(name + "_sync", run, graph, input)
 
 
+# Pick a handful of graphs to measure the first event latency.
+# At the moment, limiting just due to the size of the annotation on github.
+GRAPHS_FOR_1st_EVENT_LATENCY = (
+    "sequential_1000",
+    "pydantic_state_25x300",
+)
+
 # First event latency
 for name, agraph, graph, input in benchmarks:
+    if graph not in GRAPHS_FOR_1st_EVENT_LATENCY:
+        continue
     r.bench_async_func(
         name + "_first_event_latency",
         arun_first_event_latency,
@@ -403,30 +400,14 @@ compilation_benchmarks = (
         "sequential_1000",
         create_sequential(1_000),
     ),
-    (
-        "sequential_10000",
-        create_sequential(10_000),
-    ),
     (
         "pydantic_state_25x300",
         pydantic_state(300),
     ),
-    (
-        "pydantic_state_15x600",
-        pydantic_state(600),
-    ),
-    (
-        "pydantic_state_9x1200",
-        pydantic_state(1200),
-    ),
     (
         "wide_state_15x600",
         wide_state(600),
     ),
-    (
-        "wide_state_9x1200",
-        wide_state(1200),
-    ),
 )
 
 for name, graph in compilation_benchmarks:

libs/langgraph/langgraph/channels/topic.py

@@ -62,7 +62,7 @@ class Topic(
                 empty.values = checkpoint
         return empty
 
-    def update(self, values: Sequence[Union[Value, list[Value]]]) -> None:
+    def update(self, values: Sequence[Union[Value, list[Value]]]) -> bool:
         current = list(self.values)
         if not self.accumulate:
             self.values = list[Value]()

libs/langgraph/langgraph/config.py

@@ -118,6 +118,17 @@ def get_store() -> BaseStore:
     return config[CONF][CONFIG_KEY_STORE]
 
 
+def set_store(store: BaseStore) -> None:
+    """Set LangGraph store in context."""
+    var_config = var_child_runnable_config.get()
+    if not var_config:
+        var_config = {CONF: {CONFIG_KEY_STORE: store}}
+        var_child_runnable_config.set(var_config)
+    else:
+        var_config[CONF][CONFIG_KEY_STORE] = store
+        var_child_runnable_config.set(var_config)
+
+
 def get_stream_writer() -> StreamWriter:
     """Access LangGraph [StreamWriter][langgraph.types.StreamWriter] from inside a graph node or entrypoint task at runtime.
 
@@ -183,3 +194,14 @@ def get_stream_writer() -> StreamWriter:
     """
     config = get_config()
     return config[CONF].get(CONFIG_KEY_STREAM_WRITER, _no_op_stream_writer)
+
+
+def set_stream_writer(stream_writer: StreamWriter) -> None:
+    """Set LangGraph stream writer in context."""
+    var_config = var_child_runnable_config.get()
+    if not var_config:
+        var_config = {CONF: {CONFIG_KEY_STREAM_WRITER: stream_writer}}
+        var_child_runnable_config.set(var_config)
+    else:
+        var_config[CONF][CONFIG_KEY_STREAM_WRITER] = stream_writer
+        var_child_runnable_config.set(var_config)

libs/langgraph/langgraph/pregel/remote.py

@@ -654,7 +654,9 @@ class RemoteGraph(PregelProtocol):
             # raise interrupt or errors
             if chunk.event.startswith("updates"):
                 if isinstance(chunk.data, dict) and INTERRUPT in chunk.data:
-                    raise GraphInterrupt(chunk.data[INTERRUPT])
+                    raise GraphInterrupt(
+                        [Interrupt(**i) for i in chunk.data[INTERRUPT]]
+                    )
             elif chunk.event.startswith("error"):
                 raise RemoteException(chunk.data)
             # filter for what was actually requested
@@ -746,7 +748,9 @@ class RemoteGraph(PregelProtocol):
             # raise interrupt or errors
             if chunk.event.startswith("updates"):
                 if isinstance(chunk.data, dict) and INTERRUPT in chunk.data:
-                    raise GraphInterrupt(chunk.data[INTERRUPT])
+                    raise GraphInterrupt(
+                        [Interrupt(**i) for i in chunk.data[INTERRUPT]]
+                    )
             elif chunk.event.startswith("error"):
                 raise RemoteException(chunk.data)
             # filter for what was actually requested

libs/langgraph/langgraph/types.py

@@ -101,7 +101,10 @@ def default_retry_on(exc: Exception) -> bool:
 
 
 class RetryPolicy(NamedTuple):
-    """Configuration for retrying nodes."""
+    """Configuration for retrying nodes.
+
+    !!! version-added "Added in version 0.2.24."
+    """
 
     initial_interval: float = 0.5
     """Amount of time that must elapse before the first retry occurs. In seconds."""
@@ -120,13 +123,20 @@ class RetryPolicy(NamedTuple):
 
 
 class CachePolicy(NamedTuple):
-    """Configuration for caching nodes."""
+    """Configuration for caching nodes.
+
+    !!! version-added "Added in version 0.2.24."
+    """
 
     pass
 
 
 @dataclasses.dataclass(**_DC_KWARGS)
 class Interrupt:
+    """
+    !!! version-added "Added in version 0.2.24."
+    """
+
     value: Any
     resumable: bool = False
     ns: Optional[Sequence[str]] = None
@@ -268,6 +278,8 @@ N = TypeVar("N", bound=Hashable)
 class Command(Generic[N], ToolOutputMixin):
     """One or more commands to update the graph's state and send messages to nodes.
 
+    !!! version-added "Added in version 0.2.24."
+
     Args:
         graph: graph to send the command to. Supported values are:
 

libs/prebuilt/langgraph/prebuilt/tool_node.py

@@ -292,7 +292,7 @@ class ToolNode(RunnableCallable):
                             goto=cast(list[Send], parent_command.goto) + output.goto,
                         )
                     else:
-                        parent_command = output
+                        parent_command = Command(graph=Command.PARENT, goto=output.goto)
                 else:
                     combined_outputs.append(output)
             else:

libs/prebuilt/pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "langgraph-prebuilt"
-version = "0.1.6"
+version = "0.1.7"
 description = "Library with high-level APIs for creating and executing LangGraph agents and tools."
 authors = []
 license = "MIT"

libs/sdk-js/src/schema.ts

@@ -57,25 +57,25 @@ export interface GraphSchema {
    * The schema for the input state.
    * Missing if unable to generate JSON schema from graph.
    */
-  input_schema?: JSONSchema7;
+  input_schema?: JSONSchema7 | null | undefined;
 
   /**
    * The schema for the output state.
    * Missing if unable to generate JSON schema from graph.
    */
-  output_schema?: JSONSchema7;
+  output_schema?: JSONSchema7 | null | undefined;
 
   /**
    * The schema for the graph state.
    * Missing if unable to generate JSON schema from graph.
    */
-  state_schema?: JSONSchema7;
+  state_schema?: JSONSchema7 | null | undefined;
 
   /**
    * The schema for the graph config.
    * Missing if unable to generate JSON schema from graph.
    */
-  config_schema?: JSONSchema7;
+  config_schema?: JSONSchema7 | null | undefined;
 }
 
 export type Subgraphs = Record<string, GraphSchema>;