diff --git a/src/google/adk/models/gemini_llm_connection.py b/src/google/adk/models/gemini_llm_connection.py index da508891d4..27d8edb274 100644 --- a/src/google/adk/models/gemini_llm_connection.py +++ b/src/google/adk/models/gemini_llm_connection.py @@ -310,7 +310,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,