From 18494b1aea5f87befef93cd7e7698153897f1777 Mon Sep 17 00:00:00 2001 From: goulustis Date: Mon, 5 Jan 2026 21:09:15 +0800 Subject: [PATCH] make streamable_tags property --- lang_agent/graphs/routing.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/lang_agent/graphs/routing.py b/lang_agent/graphs/routing.py index dffe26f..c5a9a97 100644 --- a/lang_agent/graphs/routing.py +++ b/lang_agent/graphs/routing.py @@ -137,7 +137,6 @@ class RoutingGraph(GraphBase): async def _astream_result(self, *nargs, **kwargs) -> AsyncIterator[str]: """Async streaming using LangGraph's astream method.""" - streamable_tags = self.tool_node.get_streamable_tags() + [["route_chat_llm"]] async def text_iterator(): async for chunk, metadata in self.workflow.astream( @@ -150,7 +149,7 @@ class RoutingGraph(GraphBase): chunk, metadata = metadata tags = metadata.get("tags") - if not (tags in streamable_tags): + if not (tags in self.streamable_tags): continue if isinstance(chunk, (BaseMessageChunk, BaseMessage)) and getattr(chunk, "content", None):