Merge branch '1.0-dev' into ishymko/push-notifications

Author: ishymko

CHANGELOG.md

@@ -1,5 +1,38 @@
 # Changelog
 
+## [0.3.24](https://github.com/a2aproject/a2a-python/compare/v0.3.23...v0.3.24) (2026-02-20)
+
+
+### Bug Fixes
+
+* **core:** preserve legitimate falsy values in _clean_empty ([#713](https://github.com/a2aproject/a2a-python/issues/713)) ([7632f55](https://github.com/a2aproject/a2a-python/commit/7632f55572641d8fbc353ee08ef2b1f6b75c38b6))
+* **deps:** `DeprecationWarning` on `HTTP_413_REQUEST_ENTITY_TOO_LARGE` ([#693](https://github.com/a2aproject/a2a-python/issues/693)) ([9968f9c](https://github.com/a2aproject/a2a-python/commit/9968f9c07f105bae8a6b296aeb6dea873b3b88b0))
+
+## [0.3.23](https://github.com/a2aproject/a2a-python/compare/v0.3.22...v0.3.23) (2026-02-13)
+
+
+### Features
+
+* add async context manager support to BaseClient ([#688](https://github.com/a2aproject/a2a-python/issues/688)) ([ae9dc88](https://github.com/a2aproject/a2a-python/commit/ae9dc8897885ad26461083682dd7ba008d5af3cb))
+* add async context manager support to ClientTransport ([#682](https://github.com/a2aproject/a2a-python/issues/682)) ([2e45c0d](https://github.com/a2aproject/a2a-python/commit/2e45c0d54e47f1725b13c67c8e509b0e6e61efb6))
+* support async card modifiers ([#654](https://github.com/a2aproject/a2a-python/issues/654)) ([a802500](https://github.com/a2aproject/a2a-python/commit/a802500b3ad82845c1a6fc155f80e75a20a1bcab))
+* support disabling OTel instrumentation via env var ([#611](https://github.com/a2aproject/a2a-python/issues/611)) ([72216b9](https://github.com/a2aproject/a2a-python/commit/72216b988c0681e07d26ea8d5489a619d1ad6dda))
+
+
+### Bug Fixes
+
+* do not crash on SSE comment line ([#636](https://github.com/a2aproject/a2a-python/issues/636)) ([3dcb847](https://github.com/a2aproject/a2a-python/commit/3dcb84772fdc8a4d3b63b518ed491e5ed3d38d0a))
+* gRPC metadata header casing and invocation_metadata() call ([#676](https://github.com/a2aproject/a2a-python/issues/676)) ([390b763](https://github.com/a2aproject/a2a-python/commit/390b763d106eae3b2ca8ca78a2d0bfdc68f8fe2c))
+* Improve error handling for Timeout exceptions on REST and JSON-RPC clients ([#690](https://github.com/a2aproject/a2a-python/issues/690)) ([2acd838](https://github.com/a2aproject/a2a-python/commit/2acd838796d44ab9bfe6ba8c8b4ea0c2571a59dc))
+* map rejected task state in proto converters ([#668](https://github.com/a2aproject/a2a-python/issues/668)) ([957e92b](https://github.com/a2aproject/a2a-python/commit/957e92b9059792c44a40bbab18160996f5512145)), closes [#625](https://github.com/a2aproject/a2a-python/issues/625)
+* **server:** fix deadlocks on agent execution failure in non-streaming ([#614](https://github.com/a2aproject/a2a-python/issues/614)) ([d3c973f](https://github.com/a2aproject/a2a-python/commit/d3c973fe72afc0142f8a4c94d0c0fbe4ba2ddfe8))
+
+
+### Documentation
+
+* explicitly mention supported spec version and transports in readme ([#681](https://github.com/a2aproject/a2a-python/issues/681)) ([c91d4fb](https://github.com/a2aproject/a2a-python/commit/c91d4fba517190d8f7c76b42ea26914a4275f1d5)), closes [#677](https://github.com/a2aproject/a2a-python/issues/677)
+* Update README to include Code Wiki badge ([2698cc0](https://github.com/a2aproject/a2a-python/commit/2698cc04f15282fb358018f06bd88ae159d987b4))
+
 ## [0.3.22](https://github.com/a2aproject/a2a-python/compare/v0.3.21...v0.3.22) (2025-12-16)
 
 

Gemini.md GEMINI.mdGemini.md renamed to GEMINI.md

@@ -3,25 +3,18 @@
 ## Project frameworks
 - uv as package manager
 
-## How to run all tests
-1. If dependencies are not installed, install them using the following command
-   ```
-   uv sync --all-extras 
-   ```
-
-2. Run tests
-  ```
-  uv run pytest
-  ```
-
-## Other instructions
+## Code style and mandatory checks
 1. Whenever writing python code, write types as well.
 2. After making the changes run ruff to check and fix the formatting issues
    ```
    uv run ruff check --fix
+   uv run ruff format
    ```
 3. Run mypy type checkers to check for type errors
    ```
-   uv run mypy
+   uv run mypy src
    ```
 4. Run the unit tests to make sure that none of the unit tests are broken.
+  ```
+  uv run pytest
+  ```

buf.gen.yaml

@@ -2,7 +2,7 @@
 version: v2
 inputs:
   - git_repo: https://github.com/a2aproject/A2A.git
-    ref: v1.0.0-rc
+    ref: main
     subdir: specification
 managed:
   enabled: true

scripts/gen_proto.sh

@@ -2,7 +2,7 @@
 set -e
 
 # Run buf generate to regenerate protobuf code and OpenAPI spec
-npx @bufbuild/buf generate
+npx --yes @bufbuild/buf generate
 
 # The OpenAPI generator produces a file named like 'a2a.swagger.json' or similar.
 # We need it to be 'a2a.json' for the A2A SDK.

src/a2a/client/client_factory.py

@@ -20,9 +20,7 @@
     AgentInterface,
 )
 from a2a.utils.constants import (
-    TRANSPORT_GRPC,
-    TRANSPORT_HTTP_JSON,
-    TRANSPORT_JSONRPC,
+    TransportProtocol,
 )
 
 
@@ -74,9 +72,9 @@ def __init__(
 
     def _register_defaults(self, supported: list[str]) -> None:
         # Empty support list implies JSON-RPC only.
-        if TRANSPORT_JSONRPC in supported or not supported:
+        if TransportProtocol.JSONRPC in supported or not supported:
             self.register(
-                TRANSPORT_JSONRPC,
+                TransportProtocol.JSONRPC,
                 lambda card, url, config, interceptors: JsonRpcTransport(
                     config.httpx_client or httpx.AsyncClient(),
                     card,
@@ -85,9 +83,9 @@ def _register_defaults(self, supported: list[str]) -> None:
                     config.extensions or None,
                 ),
             )
-        if TRANSPORT_HTTP_JSON in supported:
+        if TransportProtocol.HTTP_JSON in supported:
             self.register(
-                TRANSPORT_HTTP_JSON,
+                TransportProtocol.HTTP_JSON,
                 lambda card, url, config, interceptors: RestTransport(
                     config.httpx_client or httpx.AsyncClient(),
                     card,
@@ -96,14 +94,14 @@ def _register_defaults(self, supported: list[str]) -> None:
                     config.extensions or None,
                 ),
             )
-        if TRANSPORT_GRPC in supported:
+        if TransportProtocol.GRPC in supported:
             if GrpcTransport is None:
                 raise ImportError(
                     'To use GrpcClient, its dependencies must be installed. '
                     'You can install them with \'pip install "a2a-sdk[grpc]"\''
                 )
             self.register(
-                TRANSPORT_GRPC,
+                TransportProtocol.GRPC,
                 GrpcTransport.create,
             )
 
@@ -207,7 +205,7 @@ def create(
           server configuration, a `ValueError` is raised.
         """
         client_set = self._config.supported_protocol_bindings or [
-            TRANSPORT_JSONRPC
+            TransportProtocol.JSONRPC
         ]
         transport_protocol = None
         transport_url = None

src/a2a/client/transports/jsonrpc.py

@@ -11,7 +11,6 @@
 from httpx_sse import SSEError, aconnect_sse
 from jsonrpc.jsonrpc2 import JSONRPC20Request, JSONRPC20Response
 
-from a2a.client.card_resolver import A2ACardResolver
 from a2a.client.errors import (
     A2AClientHTTPError,
     A2AClientJSONError,
@@ -53,31 +52,18 @@ class JsonRpcTransport(ClientTransport):
     def __init__(
         self,
         httpx_client: httpx.AsyncClient,
-        agent_card: AgentCard | None = None,
-        url: str | None = None,
+        agent_card: AgentCard,
+        url: str,
         interceptors: list[ClientCallInterceptor] | None = None,
         extensions: list[str] | None = None,
     ):
         """Initializes the JsonRpcTransport."""
-        if url:
-            self.url = url
-        elif agent_card:
-            if agent_card.supported_interfaces:
-                self.url = agent_card.supported_interfaces[0].url
-            else:
-                # Fallback or error if no interfaces?
-                # For compatibility we might check if 'url' attr exists (it does not on proto anymore)
-                raise ValueError('AgentCard has no supported interfaces')
-        else:
-            raise ValueError('Must provide either agent_card or url')
-
+        self.url = url
         self.httpx_client = httpx_client
         self.agent_card = agent_card
         self.interceptors = interceptors or []
         self.extensions = extensions
-        self._needs_extended_card = (
-            agent_card.capabilities.extended_agent_card if agent_card else True
-        )
+        self._needs_extended_card = agent_card.capabilities.extended_agent_card
 
     async def _apply_interceptors(
         self,
@@ -513,15 +499,6 @@ async def get_extended_agent_card(
 
         card = self.agent_card
 
-        if not card:
-            resolver = A2ACardResolver(self.httpx_client, self.url)
-            card = await resolver.get_agent_card(
-                http_kwargs=modified_kwargs,
-                signature_verifier=signature_verifier,
-            )
-            self.agent_card = card
-            self._needs_extended_card = card.capabilities.extended_agent_card
-
         if not card.capabilities.extended_agent_card:
             return card
 

src/a2a/client/transports/rest.py

@@ -10,7 +10,6 @@
 from google.protobuf.message import Message
 from httpx_sse import SSEError, aconnect_sse
 
-from a2a.client.card_resolver import A2ACardResolver
 from a2a.client.errors import (
     A2AClientHTTPError,
     A2AClientJSONError,
@@ -37,10 +36,6 @@
     Task,
     TaskPushNotificationConfig,
 )
-from a2a.utils.constants import (
-    TRANSPORT_HTTP_JSON,
-    TRANSPORT_JSONRPC,
-)
 from a2a.utils.telemetry import SpanKind, trace_class
 
 
@@ -54,37 +49,17 @@ class RestTransport(ClientTransport):
     def __init__(
         self,
         httpx_client: httpx.AsyncClient,
-        agent_card: AgentCard | None = None,
-        url: str | None = None,
+        agent_card: AgentCard,
+        url: str,
         interceptors: list[ClientCallInterceptor] | None = None,
         extensions: list[str] | None = None,
     ):
         """Initializes the RestTransport."""
-        if url:
-            self.url = url
-        elif agent_card:
-            for interface in agent_card.supported_interfaces:
-                if interface.protocol_binding in (
-                    TRANSPORT_HTTP_JSON,
-                    TRANSPORT_JSONRPC,
-                ):
-                    self.url = interface.url
-                    break
-            else:
-                raise ValueError(
-                    f'AgentCard does not support {TRANSPORT_HTTP_JSON} '
-                    f'or {TRANSPORT_JSONRPC}'
-                )
-        else:
-            raise ValueError('Must provide either agent_card or url')
-        if self.url.endswith('/'):
-            self.url = self.url[:-1]
+        self.url = url.removesuffix('/')
         self.httpx_client = httpx_client
         self.agent_card = agent_card
         self.interceptors = interceptors or []
-        self._needs_extended_card = (
-            agent_card.capabilities.extended_agent_card if agent_card else True
-        )
+        self._needs_extended_card = agent_card.capabilities.extended_agent_card
         self.extensions = extensions
 
     async def _apply_interceptors(
@@ -493,15 +468,6 @@ async def get_extended_agent_card(
 
         card = self.agent_card
 
-        if not card:
-            resolver = A2ACardResolver(self.httpx_client, self.url)
-            card = await resolver.get_agent_card(
-                http_kwargs=modified_kwargs,
-                signature_verifier=signature_verifier,
-            )
-            self.agent_card = card
-            self._needs_extended_card = card.capabilities.extended_agent_card
-
         if not card.capabilities.extended_agent_card:
             return card
         _, modified_kwargs = await self._apply_interceptors(

src/a2a/server/apps/jsonrpc/jsonrpc_app.py

@@ -39,7 +39,7 @@
     GetExtendedAgentCardRequest,
     GetTaskPushNotificationConfigRequest,
     GetTaskRequest,
-    ListTaskPushNotificationConfigRequest,
+    ListTaskPushNotificationConfigsRequest,
     ListTasksRequest,
     SendMessageRequest,
     SubscribeToTaskRequest,
@@ -70,7 +70,14 @@
     from starlette.exceptions import HTTPException
     from starlette.requests import Request
     from starlette.responses import JSONResponse, Response
-    from starlette.status import HTTP_413_REQUEST_ENTITY_TOO_LARGE
+
+    try:
+        # Starlette v0.48.0
+        from starlette.status import HTTP_413_CONTENT_TOO_LARGE
+    except ImportError:
+        from starlette.status import (  # type: ignore[no-redef]
+            HTTP_413_REQUEST_ENTITY_TOO_LARGE as HTTP_413_CONTENT_TOO_LARGE,
+        )
 
     _package_starlette_installed = True
 else:
@@ -82,7 +89,14 @@
         from starlette.exceptions import HTTPException
         from starlette.requests import Request
         from starlette.responses import JSONResponse, Response
-        from starlette.status import HTTP_413_REQUEST_ENTITY_TOO_LARGE
+
+        try:
+            # Starlette v0.48.0
+            from starlette.status import HTTP_413_CONTENT_TOO_LARGE
+        except ImportError:
+            from starlette.status import (
+                HTTP_413_REQUEST_ENTITY_TOO_LARGE as HTTP_413_CONTENT_TOO_LARGE,
+            )
 
         _package_starlette_installed = True
     except ImportError:
@@ -96,7 +110,7 @@
         Request = Any
         JSONResponse = Any
         Response = Any
-        HTTP_413_REQUEST_ENTITY_TOO_LARGE = Any
+        HTTP_413_CONTENT_TOO_LARGE = Any
 
 
 class StarletteUserProxy(A2AUser):
@@ -171,7 +185,7 @@ class JSONRPCApplication(ABC):
         'CancelTask': CancelTaskRequest,
         'CreateTaskPushNotificationConfig': CreateTaskPushNotificationConfigRequest,
         'GetTaskPushNotificationConfig': GetTaskPushNotificationConfigRequest,
-        'ListTaskPushNotificationConfig': ListTaskPushNotificationConfigRequest,
+        'ListTaskPushNotificationConfigs': ListTaskPushNotificationConfigsRequest,
         'DeleteTaskPushNotificationConfig': DeleteTaskPushNotificationConfigRequest,
         'SubscribeToTask': SubscribeToTaskRequest,
         'GetExtendedAgentCard': GetExtendedAgentCardRequest,
@@ -394,7 +408,7 @@ async def _handle_requests(self, request: Request) -> Response:  # noqa: PLR0911
                 None, JSONParseError(message=str(e))
             )
         except HTTPException as e:
-            if e.status_code == HTTP_413_REQUEST_ENTITY_TOO_LARGE:
+            if e.status_code == HTTP_413_CONTENT_TOO_LARGE:
                 return self._generate_error_response(
                     request_id,
                     InvalidRequestError(message='Payload too large'),
@@ -486,9 +500,9 @@ async def _process_non_streaming_request(
                         context,
                     )
                 )
-            case ListTaskPushNotificationConfigRequest():
+            case ListTaskPushNotificationConfigsRequest():
                 handler_result = (
-                    await self.handler.list_push_notification_config(
+                    await self.handler.list_push_notification_configs(
                         request_obj,
                         context,
                     )