diff --git a/src/google/adk/models/gemini_llm_connection.py b/src/google/adk/models/gemini_llm_connection.py index cf74a5b9d4..2100c77aea 100644 --- a/src/google/adk/models/gemini_llm_connection.py +++ b/src/google/adk/models/gemini_llm_connection.py @@ -409,7 +409,11 @@ async def receive(self) -> AsyncGenerator[LlmResponse, None]: yield self.__build_full_text_response(text, is_thought) text = '' is_thought = False - else: + # this condition prevents duplicate interruption signals + if ( + not (content and content.parts) + and not message.server_content.grounding_metadata + ): yield LlmResponse( interrupted=message.server_content.interrupted, model_version=self._model_version,