Merge branch 'main' into jscpd-fixes

Author: holtskinner

.git-blame-ignore-revs

@@ -0,0 +1,21 @@
+# Template taken from https://github.com/v8/v8/blob/master/.git-blame-ignore-revs.
+#
+# This file contains a list of git hashes of revisions to be ignored by git blame. These
+# revisions are considered "unimportant" in that they are unlikely to be what you are
+# interested in when blaming. Most of these will probably be commits related to linting
+# and code formatting.
+#
+# Instructions:
+# - Only large (generally automated) reformatting or renaming CLs should be
+#   added to this list. Do not put things here just because you feel they are
+#   trivial or unimportant. If in doubt, do not put it on this list.
+# - Precede each revision with a comment containing the PR title and number.
+#   For bulk work over many commits, place all commits in a block with a single
+#   comment at the top describing the work done in those commits.
+# - Only put full 40-character hashes on this list (not short hashes or any
+#   other revision reference).
+# - Append to the bottom of the file (revisions should be in chronological order
+#   from oldest to newest).
+# - Because you must use a hash, you need to append to this list in a follow-up
+#   PR to the actual reformatting PR that you are trying to ignore.
+193693836e1ed8cd361e139668323d2e267a9eaa

.github/workflows/linter.yaml

@@ -13,9 +13,10 @@ name: Lint Code Base
 #############################
 # Start the job on all push #
 #############################
-on:
-  pull_request:
-    branches: [main]
+# on:
+#   pull_request:
+#     branches: [main]
+on: workflow_dispatch
 
 ###############
 # Set the Job #

.github/workflows/python-publish.yml

@@ -0,0 +1,54 @@
+name: Publish Python Package
+
+on:
+  release:
+    types: [published]
+
+permissions:
+  contents: read
+
+jobs:
+  release-build:
+    runs-on: ubuntu-latest
+
+    steps:
+      - uses: actions/checkout@v4
+
+      - name: Install uv
+        uses: astral-sh/setup-uv@v5
+
+      - name: "Set up Python"
+        uses: actions/setup-python@v5
+        with:
+          python-version-file: "pyproject.toml"
+
+      - name: Build
+        run: uv build
+      
+      - name: Upload distributions
+        uses: actions/upload-artifact@v4
+        with:
+          name: release-dists
+          path: dist/
+
+  pypi-publish:
+    runs-on: ubuntu-latest
+    needs:
+      - release-build
+    permissions:
+      id-token: write
+
+    steps:
+      - name: Retrieve release distributions
+        uses: actions/download-artifact@v4
+        with:
+          name: release-dists
+          path: dist/
+
+      - name: Publish release distributions to PyPI
+        uses: pypa/gh-action-pypi-publish@release/v1
+        with:
+          packages-dir: dist/
+  
+        
+      

examples/langgraph/__main__.py

@@ -2,14 +2,15 @@
 import sys
 
 import click
+import httpx
 
 from agent import CurrencyAgent
 from agent_executor import CurrencyAgentExecutor
 from dotenv import load_dotenv
 
 from a2a.server.apps import A2AStarletteApplication
 from a2a.server.request_handlers import DefaultRequestHandler
-from a2a.server.tasks import InMemoryTaskStore
+from a2a.server.tasks import InMemoryPushNotifier, InMemoryTaskStore
 from a2a.types import (
     AgentAuthentication,
     AgentCapabilities,
@@ -29,9 +30,11 @@ def main(host: str, port: int):
         print('GOOGLE_API_KEY environment variable not set.')
         sys.exit(1)
 
+    client = httpx.AsyncClient()
     request_handler = DefaultRequestHandler(
         agent_executor=CurrencyAgentExecutor(),
         task_store=InMemoryTaskStore(),
+        push_notifier=InMemoryPushNotifier(client),
     )
 
     server = A2AStarletteApplication(

pyproject.toml

@@ -1,9 +1,12 @@
 [project]
 name = "a2a-sdk"
-version = "0.2.0"
+dynamic = ["version"]
 description = "A2A Python SDK"
 readme = "README.md"
+license = { file = "LICENSE" }
+authors = [{ name = "Google LLC", email = "[email protected]" }]
 requires-python = ">=3.13"
+keywords = ["A2A", "A2A SDK", "A2A Protocol", "Agent2Agent"]
 dependencies = [
     "httpx>=0.28.1",
     "httpx-sse>=0.4.0",
@@ -15,6 +18,22 @@ dependencies = [
     "typing-extensions>=4.13.2",
 ]
 
+classifiers = [
+  "Intended Audience :: Developers",
+  "Programming Language :: Python",
+  "Programming Language :: Python :: 3",
+  "Programming Language :: Python :: 3.13",
+  "Operating System :: OS Independent",
+  "Topic :: Software Development :: Libraries :: Python Modules",
+  "License :: OSI Approved :: Apache Software License",
+]
+
+[project.urls]
+homepage = "https://google.github.io/A2A/"
+repository = "https://github.com/google/a2a-python"
+changelog = "https://github.com/google/a2a-python/blob/main/CHANGELOG.md"
+documentation = "https://google.github.io/A2A/"
+
 [tool.hatch.build.targets.wheel]
 packages = ["src/a2a"]
 
@@ -25,9 +44,21 @@ python_functions = "test_*"
 addopts = "--cov=src --cov-config=.coveragerc --cov-report term --cov-report xml:coverage.xml --cov-branch"
 
 [build-system]
-requires = ["hatchling"]
+requires = ["hatchling", "uv-dynamic-versioning"]
 build-backend = "hatchling.build"
 
+[tool.hatch.version]
+source = "uv-dynamic-versioning"
+
+[tool.hatch.build.targets.sdist]
+exclude = [
+  "tests/",
+]
+
+[tool.uv-dynamic-versioning]
+vcs = "git"
+style = "pep440"
+
 [tool.uv.workspace]
 members = [
     "examples/langgraph",
@@ -45,4 +76,11 @@ dev = [
     "pytest-cov>=6.1.1",
     "pytest-mock>=3.14.0",
     "ruff>=0.11.6",
+    "uv-dynamic-versioning>=0.8.2",
 ]
+
+[[tool.uv.index]]
+name = "testpypi"
+url = "https://test.pypi.org/simple/"
+publish-url = "https://test.pypi.org/legacy/"
+explicit = true

src/a2a/client/client.py

@@ -24,6 +24,7 @@
     SetTaskPushNotificationConfigRequest,
     SetTaskPushNotificationConfigResponse,
 )
+from a2a.utils.telemetry import SpanKind, trace_class
 
 
 async def _make_httpx_request(
@@ -81,6 +82,7 @@ async def get_agent_card(
         return AgentCard.model_validate(response_json)
 
 
+@trace_class(kind=SpanKind.CLIENT)
 class A2AClient:
     """A2A Client."""
 

src/a2a/server/agent_execution/context.py

@@ -4,6 +4,7 @@
     InvalidParamsError,
     Message,
     MessageSendParams,
+    MessageSendConfiguration,
     Task,
 )
 from a2a.utils import get_message_text
@@ -79,6 +80,10 @@ def task_id(self) -> str | None:
     def context_id(self) -> str | None:
         return self._context_id
 
+    @property
+    def configuration(self) -> MessageSendConfiguration | None:
+        return self._params.configuration
+
     def _check_or_generate_task_id(self) -> None:
         if not self._params:
             return

src/a2a/server/events/event_consumer.py

@@ -12,11 +12,13 @@
     TaskStatusUpdateEvent,
 )
 from a2a.utils.errors import ServerError
+from a2a.utils.telemetry import SpanKind, trace_class
 
 
 logger = logging.getLogger(__name__)
 
 
+@trace_class(kind=SpanKind.SERVER)
 class EventConsumer:
     """Consumer to read events from the agent event queue."""
 

src/a2a/server/events/event_queue.py

@@ -11,6 +11,7 @@
     TaskArtifactUpdateEvent,
     TaskStatusUpdateEvent,
 )
+from a2a.utils.telemetry import SpanKind, trace_class
 
 
 logger = logging.getLogger(__name__)
@@ -26,6 +27,7 @@
 )
 
 
+@trace_class(kind=SpanKind.SERVER)
 class EventQueue:
     """Event queue for A2A responses from agent."""
 

src/a2a/server/events/in_memory_queue_manager.py

@@ -6,8 +6,10 @@
     QueueManager,
     TaskQueueExists,
 )
+from a2a.utils.telemetry import SpanKind, trace_class
 
 
+@trace_class(kind=SpanKind.SERVER)
 class InMemoryQueueManager(QueueManager):
     """InMemoryQueueManager is used for a single binary management.