Merge branch 'main' of https://github.com/a2aproject/a2a-python into pr/darkhaniop/217

Author: holtskinner

.github/actions/spelling/allow.txt

@@ -53,6 +53,7 @@ lifecycles
 linting
 Llm
 lstrips
+mikeas
 mockurl
 notif
 oauthoidc
@@ -77,5 +78,6 @@ sse
 tagwords
 taskupdate
 testuuid
+Tful
 typeerror
 vulnz

.github/workflows/unit-tests.yml

@@ -45,7 +45,7 @@ jobs:
         with:
           python-version: ${{ matrix.python-version }}
       - name: Set up test environment variables
-        run: |          
+        run: |
           echo "POSTGRES_TEST_DSN=postgresql+asyncpg://a2a:a2a_password@localhost:5432/a2a_test" >> $GITHUB_ENV
           echo "MYSQL_TEST_DSN=mysql+aiomysql://a2a:a2a_password@localhost:3306/a2a_test" >> $GITHUB_ENV
 
@@ -55,8 +55,8 @@ jobs:
         run: |
           echo "$HOME/.cargo/bin" >> $GITHUB_PATH
       - name: Install dependencies
-        run: uv sync --dev --extra sql --extra encryption --extra grpc
+        run: uv sync --dev --extra sql --extra encryption --extra grpc --extra telemetry
       - name: Run tests and check coverage
-        run: uv run pytest --cov=a2a --cov-report=xml --cov-fail-under=89
+        run: uv run pytest --cov=a2a --cov-report term --cov-fail-under=89
       - name: Show coverage summary in log
         run: uv run coverage report

.vscode/launch.json

@@ -47,7 +47,8 @@
         "-s"
       ],
       "console": "integratedTerminal",
-      "justMyCode": true
+      "justMyCode": true,
+      "python": "${workspaceFolder}/.venv/bin/python",
     }
   ]
-}
+}

Gemini.md

@@ -0,0 +1,27 @@
+**A2A specification:** https://a2a-protocol.org/latest/specification/
+
+## Project frameworks
+- uv as package manager
+
+## How to run all tests
+1. If dependencies are not installed install them using following command
+   ```
+   uv sync --all-extras 
+   ```
+
+2. Run tests
+  ```
+  uv run pytest
+  ```
+
+## Other instructions
+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
+   ```
+3. Run mypy type checkers to check for type errors
+   ```
+   uv run mypy
+   ```
+4. Run the unit tests to make sure that none of the unit tests are broken.

README.md

@@ -45,6 +45,12 @@ To install with gRPC support:
 uv add "a2a-sdk[grpc]"
 ```
 
+To install with OpenTelemetry tracing support:
+
+```bash
+uv add "a2a-sdk[telemetry]"
+```
+
 To install with database support:
 
 ```bash
@@ -81,6 +87,12 @@ To install with gRPC support:
 pip install "a2a-sdk[grpc]"
 ```
 
+To install with OpenTelemetry tracing support:
+
+```bash
+pip install "a2a-sdk[telemetry]"
+```
+
 To install with database support:
 
 ```bash

error_handlers.py

@@ -10,9 +10,9 @@ keywords = ["A2A", "A2A SDK", "A2A Protocol", "Agent2Agent", "Agent 2 Agent"]
 dependencies = [
   "httpx>=0.28.1",
   "httpx-sse>=0.4.0",
-  "opentelemetry-api>=1.33.0",
-  "opentelemetry-sdk>=1.33.0",
   "pydantic>=2.11.3",
+  "protobuf==5.29.5",
+  "google-api-core>=1.26.0",
 ]
 
 classifiers = [
@@ -29,13 +29,14 @@ classifiers = [
 ]
 
 [project.optional-dependencies]
-http-server = ["fastapi>=0.115.2", "sse-starlette", "starlette"]
+http-server = ["fastapi", "sse-starlette", "starlette"]
 postgresql = ["sqlalchemy[asyncio,postgresql-asyncpg]>=2.0.0"]
 mysql = ["sqlalchemy[asyncio,aiomysql]>=2.0.0"]
 sqlite = ["sqlalchemy[asyncio,aiosqlite]>=2.0.0"]
 sql = ["sqlalchemy[asyncio,postgresql-asyncpg,aiomysql,aiosqlite]>=2.0.0"]
 encryption = ["cryptography>=43.0.0"]
-grpc = ["grpcio>=1.60", "grpcio-tools>=1.60", "grpcio_reflection>=1.7.0", "protobuf==5.29.5", "google-api-core>=1.26.0"]
+grpc = ["grpcio>=1.60", "grpcio-tools>=1.60", "grpcio_reflection>=1.7.0"]
+telemetry = ["opentelemetry-api>=1.33.0", "opentelemetry-sdk>=1.33.0"]
 
 [project.urls]
 homepage = "https://a2a-protocol.org/"
@@ -92,6 +93,7 @@ dev = [
   "pyupgrade",
   "autoflake",
   "no_implicit_optional",
+  "trio",
 ]
 
 [[tool.uv.index]]

pyproject.toml

@@ -7,21 +7,24 @@
     CredentialService,
     InMemoryContextCredentialStore,
 )
-from a2a.client.client import A2ACardResolver, A2AClient
+from a2a.client.card_resolver import A2ACardResolver
+from a2a.client.client import Client, ClientConfig, ClientEvent, Consumer
+from a2a.client.client_factory import ClientFactory, minimal_agent_card
 from a2a.client.errors import (
     A2AClientError,
     A2AClientHTTPError,
     A2AClientJSONError,
     A2AClientTimeoutError,
 )
 from a2a.client.helpers import create_text_message_object
+from a2a.client.legacy import A2AClient
 from a2a.client.middleware import ClientCallContext, ClientCallInterceptor
 
 
 logger = logging.getLogger(__name__)
 
 try:
-    from a2a.client.grpc_client import A2AGrpcClient  # type: ignore
+    from a2a.client.legacy_grpc import A2AGrpcClient  # type: ignore
 except ImportError as e:
     _original_error = e
     logger.debug(
@@ -48,9 +51,15 @@ def __init__(self, *args, **kwargs):
     'A2AClientTimeoutError',
     'A2AGrpcClient',
     'AuthInterceptor',
+    'Client',
     'ClientCallContext',
     'ClientCallInterceptor',
+    'ClientConfig',
+    'ClientEvent',
+    'ClientFactory',
+    'Consumer',
     'CredentialService',
     'InMemoryContextCredentialStore',
     'create_text_message_object',
+    'minimal_agent_card',
 ]