WEBDIENSTE/langgraph
1
0
Fork 0
mirror of https://github.com/langchain-ai/langgraph.git synced 2026-08-24 16:42:24 +02:00
Code Issues Packages Projects Releases Wiki Activity

Fix async transformer example to use async iteration on channel

Browse Source
This commit is contained in:
Nick Hollon
2026-04-15 19:02:24 -04:00
parent 5b1f86facc
commit b72b5fefd0
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
examples/streaming-v2/streaming_comparison.py
+1 -1
View File
@@ -446,7 +446,7 @@ async def run_v2_async_with_transformer(question: str) -> None:
_ = await run.output
snapshots = list(run.extensions["token_metrics"])
snapshots = [s async for s in run.extensions["token_metrics"]]
final = next((s for s in snapshots if s.is_final), None)
periodic = [s for s in snapshots if not s.is_final]