pr-5097 ran autoformatter

Author: jordac

src/google/adk/models/gemini_llm_connection.py

@@ -132,7 +132,7 @@ async def send_content(self, content: types.Content):
           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')
       else:
@@ -161,9 +161,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 +176,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')]
   )