[PR #560] [MERGED] For stream_mode=updates (the default) stream the output of each node as soon as that node finishes #1538

Closed
opened 2026-02-20 17:44:59 -05:00 by yindo · 0 comments
Owner

📋 Pull Request Information

Original PR: https://github.com/langchain-ai/langgraph/pull/560
Author: @nfcampos
Created: 5/30/2024
Status: Merged
Merged: 5/31/2024
Merged by: @nfcampos

Base: mainHead: nc/30may/stream-updates-asap


📝 Commits (6)

  • 0409d70 For stream_mode=updates (the default) stream the output of each node as soon as that node finishes
  • 81a5720 Add missing metadata
  • 5ae9db8 Update ids in tests
  • ef3332f Remove nested output for packet tasks
  • 1fa327c Lint
  • 30e456b One more test, handle negative timeout

📊 Changes

6 files changed (+392 additions, -353 deletions)

View changed files

📝 langgraph/pregel/__init__.py (+95 -51)
📝 langgraph/pregel/debug.py (+8 -4)
📝 langgraph/pregel/io.py (+14 -23)
📝 langgraph/pregel/types.py (+1 -1)
📝 tests/test_pregel.py (+121 -135)
📝 tests/test_pregel_async.py (+153 -139)

📄 Description

  • currently output of each node is streamed only when all nodes in that step finish
  • checkpoint/values stream chunks still yielded only at the end of the step, as they require applying all updates

🔄 This issue represents a GitHub Pull Request. It cannot be merged through Gitea due to API limitations.

## 📋 Pull Request Information **Original PR:** https://github.com/langchain-ai/langgraph/pull/560 **Author:** [@nfcampos](https://github.com/nfcampos) **Created:** 5/30/2024 **Status:** ✅ Merged **Merged:** 5/31/2024 **Merged by:** [@nfcampos](https://github.com/nfcampos) **Base:** `main` ← **Head:** `nc/30may/stream-updates-asap` --- ### 📝 Commits (6) - [`0409d70`](https://github.com/langchain-ai/langgraph/commit/0409d70d0c8825a62e9ab3d6c420a0430820c116) For stream_mode=updates (the default) stream the output of each node as soon as that node finishes - [`81a5720`](https://github.com/langchain-ai/langgraph/commit/81a5720dd0642db0ff86cd62be47ea77699c8e80) Add missing metadata - [`5ae9db8`](https://github.com/langchain-ai/langgraph/commit/5ae9db83c7a8535de26f015e51c2622f1c6d396a) Update ids in tests - [`ef3332f`](https://github.com/langchain-ai/langgraph/commit/ef3332ff740e22c0d61868a89dc1ed426b434409) Remove nested output for packet tasks - [`1fa327c`](https://github.com/langchain-ai/langgraph/commit/1fa327cb2810919c792838f247eb459ff601d913) Lint - [`30e456b`](https://github.com/langchain-ai/langgraph/commit/30e456be915c30ee41a0b52d24b86c3170a8460e) One more test, handle negative timeout ### 📊 Changes **6 files changed** (+392 additions, -353 deletions) <details> <summary>View changed files</summary> 📝 `langgraph/pregel/__init__.py` (+95 -51) 📝 `langgraph/pregel/debug.py` (+8 -4) 📝 `langgraph/pregel/io.py` (+14 -23) 📝 `langgraph/pregel/types.py` (+1 -1) 📝 `tests/test_pregel.py` (+121 -135) 📝 `tests/test_pregel_async.py` (+153 -139) </details> ### 📄 Description - currently output of each node is streamed only when all nodes in that step finish - checkpoint/values stream chunks still yielded only at the end of the step, as they require applying all updates --- <sub>🔄 This issue represents a GitHub Pull Request. It cannot be merged through Gitea due to API limitations.</sub>
yindo added the pull-request label 2026-02-20 17:44:59 -05:00
yindo closed this issue 2026-02-20 17:44:59 -05:00
Sign in to join this conversation.
1 Participants
Notifications
Due Date
No due date set.
Dependencies

No dependencies set.

Reference: langchain-ai/langgraph#1538