merge

Author: Kludex

pydantic_ai_slim/pydantic_ai/messages.py

@@ -385,6 +385,10 @@ def otel_event(self, _settings: InstrumentationSettings) -> Event:
             body={'content': self.content, 'role': 'tool', 'id': self.tool_call_id, 'name': self.tool_name},
         )
 
+    def has_content(self) -> bool:
+        """Return `True` if the tool return has content."""
+        return self.content is not None
+
     __repr__ = _utils.dataclasses_no_defaults_repr
 
 

pydantic_ai_slim/pydantic_ai/models/google.py

@@ -412,7 +412,7 @@ async def _get_event_iterator(self) -> AsyncIterator[ModelResponseStreamEvent]:
                 raise UnexpectedModelBehavior('Streamed response has no content field')  # pragma: no cover
             assert candidate.content.parts is not None
             for part in candidate.content.parts:
-                if part.text:
+                if part.text is not None:
                     yield self._parts_manager.handle_text_delta(vendor_part_id='content', content=part.text)
                 elif part.function_call:
                     maybe_event = self._parts_manager.handle_tool_call_delta(
@@ -463,14 +463,15 @@ def _process_response_from_parts(
         if part.executable_code is not None:
             items.append(ServerToolCallPart(args=part.executable_code.model_dump(), tool_name='code_execution'))
         elif part.code_execution_result is not None:
+            # TODO(Marcelo): Is the idea to generate the tool_call_id on the `executable_code`, and then pass it here?
             items.append(
                 ServerToolReturnPart(
                     tool_name='code_execution',
                     content=part.code_execution_result.output,
                     tool_call_id="It doesn't have.",
                 )
             )
-        elif part.text:
+        elif part.text is not None:
             items.append(TextPart(content=part.text))
         elif part.function_call:
             assert part.function_call.name is not None