run autoformatter per pr comment

Author: jordac

src/google/adk/models/gemini_llm_connection.py

@@ -122,19 +122,15 @@ async def send_content(self, content: types.Content):
       is_gemini_api = self._api_backend == GoogleLLMVariant.GEMINI_API
 
       # Route via send_realtime_input if audio is active OR if targeting 3.1 API
-      if self._audio_active or (is_gemini_31 and is_gemini_api):
+      if (self._audio_active or (is_gemini_31 and is_gemini_api)) and all(
+          isinstance(part.text, str) for part in content.parts
+      ):
         logger.debug(
             'Routing text via send_realtime_input %s',
             content,
         )
-        has_text = False
         for part in content.parts:
-          if isinstance(part.text, str):
-            await self._gemini_session.send_realtime_input(text=part.text)
-            has_text = True
-            
-        if not has_text:
-          logger.warning('Encountered unsupported content in send_content')
+          await self._gemini_session.send_realtime_input(text=part.text)
       else:
         logger.debug('Sending LLM new content %s', content)
         await self._gemini_session.send(
@@ -161,9 +157,13 @@ async def send_realtime(self, input: RealtimeInput):
       # As of now, Gemini 3.1 Flash Live is only available in Gemini API, not
       # Vertex AI.
       if is_gemini_31 and is_gemini_api:
-        if isinstance(input.mime_type, str) and input.mime_type.startswith('audio/'):
+        if isinstance(input.mime_type, str) and input.mime_type.startswith(
+            'audio/'
+        ):
           await self._gemini_session.send_realtime_input(audio=input)
-        elif isinstance(input.mime_type, str) and input.mime_type.startswith('image/'):
+        elif isinstance(input.mime_type, str) and input.mime_type.startswith(
+            'image/'
+        ):
           await self._gemini_session.send_realtime_input(video=input)
         else:
           logger.warning(
@@ -172,9 +172,13 @@ async def send_realtime(self, input: RealtimeInput):
               input.mime_type,
           )
       else:
-        if isinstance(input.mime_type, str) and input.mime_type.startswith('video/'):
+        if isinstance(input.mime_type, str) and input.mime_type.startswith(
+            'video/'
+        ):
           await self._gemini_session.send_realtime_input(video=input)
-        elif isinstance(input.mime_type, str) and input.mime_type.startswith('audio/'):
+        elif isinstance(input.mime_type, str) and input.mime_type.startswith(
+            'audio/'
+        ):
           await self._gemini_session.send_realtime_input(audio=input)
         else:
           await self._gemini_session.send_realtime_input(media=input)

tests/unittests/models/test_gemini_llm_connection.py

@@ -112,11 +112,11 @@ async def test_send_history(gemini_connection, mock_gemini_session):
 @pytest.mark.asyncio
 async def test_send_content_text(gemini_connection, mock_gemini_session):
   """Test send_content with text content when audio is inactive.
-  
+
   Note: gemini_connection._audio_active is False by default.
   """
   assert gemini_connection._audio_active is False
-  
+
   content = types.Content(
       role='user', parts=[types.Part.from_text(text='Hello')]
   )
@@ -131,10 +131,12 @@ async def test_send_content_text(gemini_connection, mock_gemini_session):
 
 
 @pytest.mark.asyncio
-async def test_send_content_text_audio_active(gemini_connection, mock_gemini_session):
+async def test_send_content_text_audio_active(
+    gemini_connection, mock_gemini_session
+):
   """Test send_content routes to send_realtime_input when audio is active."""
   gemini_connection._audio_active = True
-  
+
   content = types.Content(
       role='user', parts=[types.Part.from_text(text='Hello')]
   )
@@ -145,6 +147,31 @@ async def test_send_content_text_audio_active(gemini_connection, mock_gemini_ses
   mock_gemini_session.send.assert_not_called()
 
 
+@pytest.mark.asyncio
+async def test_send_content_mixed_audio_active(
+    gemini_connection, mock_gemini_session, test_blob
+):
+  """Test send_content falls back to LiveClientContent for mixed modalities."""
+  gemini_connection._audio_active = True
+
+  content = types.Content(
+      role='user',
+      parts=[
+          types.Part.from_text(text='Hello'),
+          types.Part(inline_data=test_blob)
+      ]
+  )
+
+  await gemini_connection.send_content(content)
+
+  mock_gemini_session.send.assert_called_once()
+  call_args = mock_gemini_session.send.call_args[1]
+  assert 'input' in call_args
+  assert call_args['input'].turns == [content]
+  assert call_args['input'].turn_complete is True
+  mock_gemini_session.send_realtime_input.assert_not_called()
+
+
 @pytest.mark.asyncio
 async def test_send_content_function_response(
     gemini_connection, mock_gemini_session