Merge branch 'main' into dependabot/github_actions/github-actions-666c6d1e80

Author: holtskinner

CHANGELOG.md

@@ -1,5 +1,12 @@
 # Changelog
 
+## [0.3.11](https://github.com/a2aproject/a2a-python/compare/v0.3.10...v0.3.11) (2025-11-07)
+
+
+### Bug Fixes
+
+* add metadata to send message request ([12b4a1d](https://github.com/a2aproject/a2a-python/commit/12b4a1d565a53794f5b55c8bd1728221c906ed41))
+
 ## [0.3.10](https://github.com/a2aproject/a2a-python/compare/v0.3.9...v0.3.10) (2025-10-21)
 
 

src/a2a/client/base_client.py

@@ -1,4 +1,5 @@
 from collections.abc import AsyncIterator
+from typing import Any
 
 from a2a.client.client import (
     Client,
@@ -47,6 +48,7 @@ async def send_message(
         request: Message,
         *,
         context: ClientCallContext | None = None,
+        request_metadata: dict[str, Any] | None = None,
     ) -> AsyncIterator[ClientEvent | Message]:
         """Sends a message to the agent.
 
@@ -57,6 +59,7 @@ async def send_message(
         Args:
             request: The message to send to the agent.
             context: The client call context.
+            request_metadata: Extensions Metadata attached to the request.
 
         Yields:
             An async iterator of `ClientEvent` or a final `Message` response.
@@ -70,7 +73,9 @@ async def send_message(
                 else None
             ),
         )
-        params = MessageSendParams(message=request, configuration=config)
+        params = MessageSendParams(
+            message=request, configuration=config, metadata=request_metadata
+        )
 
         if not self._config.streaming or not self._card.capabilities.streaming:
             response = await self._transport.send_message(

src/a2a/client/client.py

@@ -110,6 +110,7 @@ async def send_message(
         request: Message,
         *,
         context: ClientCallContext | None = None,
+        request_metadata: dict[str, Any] | None = None,
     ) -> AsyncIterator[ClientEvent | Message]:
         """Sends a message to the server.
 

src/a2a/utils/proto_utils.py

@@ -57,7 +57,7 @@ def make_dict_serializable(value: Any) -> Any:
     Returns:
         A serializable value.
     """
-    if isinstance(value, (str, int, float, bool)) or value is None:
+    if isinstance(value, str | int | float | bool) or value is None:
         return value
     if isinstance(value, dict):
         return {k: make_dict_serializable(v) for k, v in value.items()}
@@ -140,6 +140,7 @@ def message(cls, message: types.Message | None) -> a2a_pb2.Message | None:
             task_id=message.task_id or '',
             role=cls.role(message.role),
             metadata=cls.metadata(message.metadata),
+            extensions=message.extensions or [],
         )
 
     @classmethod
@@ -239,6 +240,7 @@ def artifact(cls, artifact: types.Artifact) -> a2a_pb2.Artifact:
             metadata=cls.metadata(artifact.metadata),
             name=artifact.name,
             parts=[cls.part(p) for p in artifact.parts],
+            extensions=artifact.extensions or [],
         )
 
     @classmethod
@@ -695,6 +697,7 @@ def artifact(cls, artifact: a2a_pb2.Artifact) -> types.Artifact:
             metadata=cls.metadata(artifact.metadata),
             name=artifact.name,
             parts=[cls.part(p) for p in artifact.parts],
+            extensions=artifact.extensions or None,
         )
 
     @classmethod

tests/client/test_base_client.py

@@ -73,9 +73,14 @@ async def create_stream(*args, **kwargs):
 
     mock_transport.send_message_streaming.return_value = create_stream()
 
-    events = [event async for event in base_client.send_message(sample_message)]
+    meta = {'test': 1}
+    stream = base_client.send_message(sample_message, request_metadata=meta)
+    events = [event async for event in stream]
 
     mock_transport.send_message_streaming.assert_called_once()
+    assert (
+        mock_transport.send_message_streaming.call_args[0][0].metadata == meta
+    )
     assert not mock_transport.send_message.called
     assert len(events) == 1
     assert events[0][0].id == 'task-123'
@@ -92,9 +97,12 @@ async def test_send_message_non_streaming(
         status=TaskStatus(state=TaskState.completed),
     )
 
-    events = [event async for event in base_client.send_message(sample_message)]
+    meta = {'test': 1}
+    stream = base_client.send_message(sample_message, request_metadata=meta)
+    events = [event async for event in stream]
 
     mock_transport.send_message.assert_called_once()
+    assert mock_transport.send_message.call_args[0][0].metadata == meta
     assert not mock_transport.send_message_streaming.called
     assert len(events) == 1
     assert events[0][0].id == 'task-456'