diff --git a/src/google/adk/models/gemini_llm_connection.py b/src/google/adk/models/gemini_llm_connection.py index 5cd1976f41..caa78a4b7c 100644 --- a/src/google/adk/models/gemini_llm_connection.py +++ b/src/google/adk/models/gemini_llm_connection.py @@ -342,7 +342,11 @@ async def receive(self) -> AsyncGenerator[LlmResponse, None]: if text: yield self.__build_full_text_response(text) text = '' - 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,