Merge branch '1.0-dev' into ishymko/merge-main-1.0-dev

# Conflicts:
#	CHANGELOG.md
#	tests/client/transports/test_rest_client.py
#	tests/utils/test_proto_utils.py

Author: ishymko

.github/workflows/unit-tests.yml

@@ -2,7 +2,7 @@
 name: Run Unit Tests
 on:
   pull_request:
-    branches: [main]
+    branches: [main, 1.0-dev]
 permissions:
   contents: read
 jobs:

CHANGELOG.md

@@ -40,6 +40,7 @@
 
 * return updated `agent_card` in `JsonRpcTransport.get_card()` ([#552](https://github.com/a2aproject/a2a-python/issues/552)) ([0ce239e](https://github.com/a2aproject/a2a-python/commit/0ce239e98f67ccbf154f2edcdbcee43f3b080ead))
 
+
 ## [0.3.17](https://github.com/a2aproject/a2a-python/compare/v0.3.16...v0.3.17) (2025-11-24)
 
 
@@ -86,6 +87,20 @@
 ## [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.12](https://github.com/a2aproject/a2a-python/compare/v0.3.11...v0.3.12) (2025-11-12)
+
+
+### Bug Fixes
+
+* **grpc:** Add `extensions` to `Artifact` converters. ([#523](https://github.com/a2aproject/a2a-python/issues/523)) ([c03129b](https://github.com/a2aproject/a2a-python/commit/c03129b99a663ae1f1ae72f20e4ead7807ede941))
+
+## [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))

src/a2a/client/base_client.py

@@ -15,6 +15,8 @@
 from a2a.types import (
     AgentCard,
     GetTaskPushNotificationConfigParams,
+    ListTasksParams,
+    ListTasksResult,
     Message,
     MessageSendConfiguration,
     MessageSendParams,
@@ -157,6 +159,15 @@ async def get_task(
             request, context=context, extensions=extensions
         )
 
+    async def list_tasks(
+        self,
+        request: ListTasksParams,
+        *,
+        context: ClientCallContext | None = None,
+    ) -> ListTasksResult:
+        """Retrieves tasks for an agent."""
+        return await self._transport.list_tasks(request, context=context)
+
     async def cancel_task(
         self,
         request: TaskIdParams,

src/a2a/client/client.py

@@ -12,6 +12,8 @@
 from a2a.types import (
     AgentCard,
     GetTaskPushNotificationConfigParams,
+    ListTasksParams,
+    ListTasksResult,
     Message,
     PushNotificationConfig,
     Task,
@@ -137,6 +139,15 @@ async def get_task(
     ) -> Task:
         """Retrieves the current state and history of a specific task."""
 
+    @abstractmethod
+    async def list_tasks(
+        self,
+        request: ListTasksParams,
+        *,
+        context: ClientCallContext | None = None,
+    ) -> ListTasksResult:
+        """Retrieves tasks for an agent."""
+
     @abstractmethod
     async def cancel_task(
         self,

src/a2a/client/transports/base.py

@@ -5,6 +5,8 @@
 from a2a.types import (
     AgentCard,
     GetTaskPushNotificationConfigParams,
+    ListTasksParams,
+    ListTasksResult,
     Message,
     MessageSendParams,
     Task,
@@ -53,6 +55,15 @@ async def get_task(
     ) -> Task:
         """Retrieves the current state and history of a specific task."""
 
+    @abstractmethod
+    async def list_tasks(
+        self,
+        request: ListTasksParams,
+        *,
+        context: ClientCallContext | None = None,
+    ) -> ListTasksResult:
+        """Retrieves tasks for an agent."""
+
     @abstractmethod
     async def cancel_task(
         self,

src/a2a/client/transports/grpc.py

@@ -2,6 +2,8 @@
 
 from collections.abc import AsyncGenerator, Callable
 
+from a2a.utils.constants import DEFAULT_LIST_TASKS_PAGE_SIZE
+
 
 try:
     import grpc
@@ -22,6 +24,8 @@
 from a2a.types import (
     AgentCard,
     GetTaskPushNotificationConfigParams,
+    ListTasksParams,
+    ListTasksResult,
     Message,
     MessageSendParams,
     Task,
@@ -168,6 +172,19 @@ async def get_task(
         )
         return proto_utils.FromProto.task(task)
 
+    async def list_tasks(
+        self,
+        request: ListTasksParams,
+        *,
+        context: ClientCallContext | None = None,
+    ) -> ListTasksResult:
+        """Retrieves tasks for an agent."""
+        response = await self.stub.ListTasks(
+            proto_utils.ToProto.list_tasks_request(request)
+        )
+        page_size = request.page_size or DEFAULT_LIST_TASKS_PAGE_SIZE
+        return proto_utils.FromProto.list_tasks_result(response, page_size)
+
     async def cancel_task(
         self,
         request: TaskIdParams,

src/a2a/client/transports/jsonrpc.py

@@ -31,6 +31,10 @@
     GetTaskRequest,
     GetTaskResponse,
     JSONRPCErrorResponse,
+    ListTasksParams,
+    ListTasksRequest,
+    ListTasksResponse,
+    ListTasksResult,
     Message,
     MessageSendParams,
     SendMessageRequest,
@@ -244,6 +248,26 @@ async def get_task(
             raise A2AClientJSONRPCError(response.root)
         return response.root.result
 
+    async def list_tasks(
+        self,
+        request: ListTasksParams,
+        *,
+        context: ClientCallContext | None = None,
+    ) -> ListTasksResult:
+        """Retrieves tasks for an agent."""
+        rpc_request = ListTasksRequest(params=request, id=str(uuid4()))
+        payload, modified_kwargs = await self._apply_interceptors(
+            'tasks/list',
+            rpc_request.model_dump(mode='json', exclude_none=True),
+            self._get_http_args(context),
+            context,
+        )
+        response_data = await self._send_request(payload, modified_kwargs)
+        response = ListTasksResponse.model_validate(response_data)
+        if isinstance(response.root, JSONRPCErrorResponse):
+            raise A2AClientJSONRPCError(response.root)
+        return response.root.result
+
     async def cancel_task(
         self,
         request: TaskIdParams,

src/a2a/client/transports/rest.py

@@ -8,6 +8,7 @@
 
 from google.protobuf.json_format import MessageToDict, Parse, ParseDict
 from httpx_sse import SSEError, aconnect_sse
+from pydantic import BaseModel
 
 from a2a.client.card_resolver import A2ACardResolver
 from a2a.client.errors import A2AClientHTTPError, A2AClientJSONError
@@ -18,6 +19,8 @@
 from a2a.types import (
     AgentCard,
     GetTaskPushNotificationConfigParams,
+    ListTasksParams,
+    ListTasksResult,
     Message,
     MessageSendParams,
     Task,
@@ -28,6 +31,7 @@
     TaskStatusUpdateEvent,
 )
 from a2a.utils import proto_utils
+from a2a.utils.constants import DEFAULT_LIST_TASKS_PAGE_SIZE
 from a2a.utils.telemetry import SpanKind, trace_class
 
 
@@ -244,6 +248,28 @@ async def get_task(
         ParseDict(response_data, task)
         return proto_utils.FromProto.task(task)
 
+    async def list_tasks(
+        self,
+        request: ListTasksParams,
+        *,
+        context: ClientCallContext | None = None,
+    ) -> ListTasksResult:
+        """Retrieves tasks for an agent."""
+        _, modified_kwargs = await self._apply_interceptors(
+            request.model_dump(mode='json', exclude_none=True),
+            self._get_http_args(context),
+            context,
+        )
+        response_data = await self._send_get_request(
+            '/v1/tasks',
+            _model_to_query_params(request),
+            modified_kwargs,
+        )
+        response = a2a_pb2.ListTasksResponse()
+        ParseDict(response_data, response)
+        page_size = request.page_size or DEFAULT_LIST_TASKS_PAGE_SIZE
+        return proto_utils.FromProto.list_tasks_result(response, page_size)
+
     async def cancel_task(
         self,
         request: TaskIdParams,
@@ -415,3 +441,21 @@ async def get_card(
     async def close(self) -> None:
         """Closes the httpx client."""
         await self.httpx_client.aclose()
+
+
+def _model_to_query_params(instance: BaseModel) -> dict[str, str]:
+    data = instance.model_dump(mode='json', exclude_none=True)
+    return _json_to_query_params(data)
+
+
+def _json_to_query_params(data: dict[str, Any]) -> dict[str, str]:
+    query_dict = {}
+    for key, value in data.items():
+        if isinstance(value, list):
+            query_dict[key] = ','.join(map(str, value))
+        elif isinstance(value, bool):
+            query_dict[key] = str(value).lower()
+        else:
+            query_dict[key] = str(value)
+
+    return query_dict