From 99f98b0a8b8bdd55d6674cb55ea1116bbcb67ea3 Mon Sep 17 00:00:00 2001 From: vonhutuan Date: Mon, 2 Mar 2026 21:33:47 +0700 Subject: [PATCH 1/2] fix: ensure interrupted signal is emitted when flushing text in GeminiLlmConnection --- src/google/adk/models/gemini_llm_connection.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/src/google/adk/models/gemini_llm_connection.py b/src/google/adk/models/gemini_llm_connection.py index 63606b21b0..deb1f11811 100644 --- a/src/google/adk/models/gemini_llm_connection.py +++ b/src/google/adk/models/gemini_llm_connection.py @@ -281,8 +281,7 @@ async def receive(self) -> AsyncGenerator[LlmResponse, None]: if text: yield self.__build_full_text_response(text) text = '' - else: - yield LlmResponse(interrupted=message.server_content.interrupted) + yield LlmResponse(interrupted=message.server_content.interrupted) if message.tool_call: if text: yield self.__build_full_text_response(text) From 1f7a004f525170e1b72cc63781bd91031cd04d06 Mon Sep 17 00:00:00 2001 From: vonhutuan Date: Mon, 2 Mar 2026 22:03:58 +0700 Subject: [PATCH 2/2] fix: avoid duplicate interruption signals --- src/google/adk/models/gemini_llm_connection.py | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/src/google/adk/models/gemini_llm_connection.py b/src/google/adk/models/gemini_llm_connection.py index deb1f11811..1c8649f144 100644 --- a/src/google/adk/models/gemini_llm_connection.py +++ b/src/google/adk/models/gemini_llm_connection.py @@ -180,9 +180,7 @@ async def receive(self) -> AsyncGenerator[LlmResponse, None]: if message.server_content: content = message.server_content.model_turn if content and content.parts: - llm_response = LlmResponse( - content=content, interrupted=message.server_content.interrupted - ) + llm_response = LlmResponse(content=content) if content.parts[0].text: text += content.parts[0].text llm_response.partial = True