From dfa557f39750d35c621745974ac5bc0feff75fb7 Mon Sep 17 00:00:00 2001 From: goulustis Date: Fri, 30 Jan 2026 17:06:56 +0800 Subject: [PATCH] remove stream print --- lang_agent/base.py | 4 ---- 1 file changed, 4 deletions(-) diff --git a/lang_agent/base.py b/lang_agent/base.py index 927991f..deb9811 100644 --- a/lang_agent/base.py +++ b/lang_agent/base.py @@ -59,8 +59,6 @@ class GraphBase(ABC): text_releaser = TextReleaser(*self.textreleaser_delay_keys) logger.info("streaming output") for chunk in text_releaser.release(text_iterator()): - if isinstance(chunk, str): - print(f"\033[92m{chunk}\033[0m", end="", flush=True) yield chunk # NOTE: DEFAULT IMPLEMENTATION; Overide to support your class @@ -133,8 +131,6 @@ class GraphBase(ABC): text_releaser = AsyncTextReleaser(*self.textreleaser_delay_keys) logger.info("streaming output") async for chunk in text_releaser.release(text_iterator()): - if isinstance(chunk, str): - print(f"\033[92m{chunk}\033[0m", end="", flush=True) yield chunk def _validate_input(self, *nargs, **kwargs):