refactor(live): Use send_client_content to send conversation history

The `send` method was deprecated.

Co-authored-by: Liang Wu <wuliang@google.com>
PiperOrigin-RevId: 899826160

Author: wuliang229

src/google/adk/evaluation/agent_evaluator.py

@@ -90,7 +90,7 @@ class _EvalMetricResultWithInvocation(BaseModel):
   """
 
   actual_invocation: Invocation
-  expected_invocation: Optional[Invocation] = None
+  expected_invocation: Invocation
   eval_metric_result: EvalMetricResult
 
 
@@ -438,21 +438,15 @@ def _print_details(
           "threshold": threshold,
           "prompt": AgentEvaluator._convert_content_to_text(
               per_invocation_result.expected_invocation.user_content
-              if per_invocation_result.expected_invocation
-              else per_invocation_result.actual_invocation.user_content
           ),
           "expected_response": AgentEvaluator._convert_content_to_text(
               per_invocation_result.expected_invocation.final_response
-              if per_invocation_result.expected_invocation
-              else None
           ),
           "actual_response": AgentEvaluator._convert_content_to_text(
               per_invocation_result.actual_invocation.final_response
           ),
           "expected_tool_calls": AgentEvaluator._convert_tool_calls_to_text(
               per_invocation_result.expected_invocation.intermediate_data
-              if per_invocation_result.expected_invocation
-              else None
           ),
           "actual_tool_calls": AgentEvaluator._convert_tool_calls_to_text(
               per_invocation_result.actual_invocation.intermediate_data

src/google/adk/models/gemini_llm_connection.py

@@ -81,11 +81,9 @@ async def send_history(self, history: list[types.Content]):
 
     if contents:
       logger.debug('Sending history to live connection: %s', contents)
-      await self._gemini_session.send(
-          input=types.LiveClientContent(
-              turns=contents,
-              turn_complete=contents[-1].role == 'user',
-          ),
+      await self._gemini_session.send_client_content(
+          turns=contents,
+          turn_complete=contents[-1].role == 'user',
       )
     else:
       logger.info('no content is sent')

tests/unittests/models/test_gemini_llm_connection.py

@@ -81,11 +81,11 @@ async def test_send_history(gemini_connection, mock_gemini_session):
 
   await gemini_connection.send_history(history)
 
-  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 == history
-  assert call_args['input'].turn_complete is False  # Last message is from model
+  mock_gemini_session.send_client_content.assert_called_once()
+  call_args = mock_gemini_session.send_client_content.call_args[1]
+  assert 'turns' in call_args
+  assert call_args['turns'] == history
+  assert call_args['turn_complete'] is False  # Last message is from model
 
 
 @pytest.mark.asyncio
@@ -668,9 +668,9 @@ async def test_send_history_filters_audio(mock_gemini_session, audio_part):
 
   await connection.send_history(history)
 
-  mock_gemini_session.send.assert_called_once()
-  call_args = mock_gemini_session.send.call_args[1]
-  sent_contents = call_args['input'].turns
+  mock_gemini_session.send_client_content.assert_called_once()
+  call_args = mock_gemini_session.send_client_content.call_args[1]
+  sent_contents = call_args['turns']
   # Only the model response should be sent (user audio filtered out)
   assert len(sent_contents) == 1
   assert sent_contents[0].role == 'model'
@@ -696,9 +696,9 @@ async def test_send_history_keeps_image_data(mock_gemini_session):
 
   await connection.send_history(history)
 
-  mock_gemini_session.send.assert_called_once()
-  call_args = mock_gemini_session.send.call_args[1]
-  sent_contents = call_args['input'].turns
+  mock_gemini_session.send_client_content.assert_called_once()
+  call_args = mock_gemini_session.send_client_content.call_args[1]
+  sent_contents = call_args['turns']
   # Both contents should be sent (image is not filtered)
   assert len(sent_contents) == 2
   assert sent_contents[0].parts[0].inline_data == image_blob
@@ -728,9 +728,9 @@ async def test_send_history_mixed_content_filters_only_audio(
 
   await connection.send_history(history)
 
-  mock_gemini_session.send.assert_called_once()
-  call_args = mock_gemini_session.send.call_args[1]
-  sent_contents = call_args['input'].turns
+  mock_gemini_session.send_client_content.assert_called_once()
+  call_args = mock_gemini_session.send_client_content.call_args[1]
+  sent_contents = call_args['turns']
   # Content should be sent but only with the text part
   assert len(sent_contents) == 1
   assert len(sent_contents[0].parts) == 1