Merge branch 'main' into experimental-types-script

Author: lkawka

CHANGELOG.md

@@ -1,5 +1,24 @@
 # Changelog
 
+## [0.3.10](https://github.com/a2aproject/a2a-python/compare/v0.3.9...v0.3.10) (2025-10-21)
+
+
+### Features
+
+* add `get_artifact_text()` helper method ([9155888](https://github.com/a2aproject/a2a-python/commit/9155888d258ca4d047002997e6674f3f15a67232))
+* Add a `ClientFactory.connect()` method for easy client creation ([d585635](https://github.com/a2aproject/a2a-python/commit/d5856359034f4d3d1e4578804727f47a3cd7c322))
+
+
+### Bug Fixes
+
+* change `MAX_CONTENT_LENGTH` (for file attachment) in json-rpc to be larger size (10mb) ([#518](https://github.com/a2aproject/a2a-python/issues/518)) ([5b81385](https://github.com/a2aproject/a2a-python/commit/5b813856b4b4e07510a4ef41980d388e47c73b8e))
+* correct `new_artifact` methods signature ([#503](https://github.com/a2aproject/a2a-python/issues/503)) ([ee026aa](https://github.com/a2aproject/a2a-python/commit/ee026aa356042b9eb212eee59fa5135b280a3077))
+
+
+### Code Refactoring
+
+* **utils:** move part helpers to their own file ([9155888](https://github.com/a2aproject/a2a-python/commit/9155888d258ca4d047002997e6674f3f15a67232))
+
 ## [0.3.9](https://github.com/a2aproject/a2a-python/compare/v0.3.8...v0.3.9) (2025-10-15)
 
 

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

@@ -91,7 +91,7 @@
         Response = Any
         HTTP_413_REQUEST_ENTITY_TOO_LARGE = Any
 
-MAX_CONTENT_LENGTH = 1_000_000
+MAX_CONTENT_LENGTH = 10_000_000
 
 
 class StarletteUserProxy(A2AUser):

src/a2a/utils/__init__.py

@@ -1,6 +1,7 @@
 """Utility functions for the A2A Python SDK."""
 
 from a2a.utils.artifact import (
+    get_artifact_text,
     new_artifact,
     new_data_artifact,
     new_text_artifact,
@@ -18,13 +19,15 @@
     create_task_obj,
 )
 from a2a.utils.message import (
-    get_data_parts,
-    get_file_parts,
     get_message_text,
-    get_text_parts,
     new_agent_parts_message,
     new_agent_text_message,
 )
+from a2a.utils.parts import (
+    get_data_parts,
+    get_file_parts,
+    get_text_parts,
+)
 from a2a.utils.task import (
     completed_task,
     new_task,
@@ -41,6 +44,7 @@
     'build_text_artifact',
     'completed_task',
     'create_task_obj',
+    'get_artifact_text',
     'get_data_parts',
     'get_file_parts',
     'get_message_text',

src/a2a/utils/artifact.py

@@ -5,10 +5,13 @@
 from typing import Any
 
 from a2a.types import Artifact, DataPart, Part, TextPart
+from a2a.utils.parts import get_text_parts
 
 
 def new_artifact(
-    parts: list[Part], name: str, description: str = ''
+    parts: list[Part],
+    name: str,
+    description: str | None = None,
 ) -> Artifact:
     """Creates a new Artifact object.
 
@@ -31,7 +34,7 @@ def new_artifact(
 def new_text_artifact(
     name: str,
     text: str,
-    description: str = '',
+    description: str | None = None,
 ) -> Artifact:
     """Creates a new Artifact object containing only a single TextPart.
 
@@ -53,7 +56,7 @@ def new_text_artifact(
 def new_data_artifact(
     name: str,
     data: dict[str, Any],
-    description: str = '',
+    description: str | None = None,
 ) -> Artifact:
     """Creates a new Artifact object containing only a single DataPart.
 
@@ -70,3 +73,16 @@ def new_data_artifact(
         name,
         description,
     )
+
+
+def get_artifact_text(artifact: Artifact, delimiter: str = '\n') -> str:
+    """Extracts and joins all text content from an Artifact's parts.
+
+    Args:
+        artifact: The `Artifact` object.
+        delimiter: The string to use when joining text from multiple TextParts.
+
+    Returns:
+        A single string containing all text content, or an empty string if no text parts are found.
+    """
+    return delimiter.join(get_text_parts(artifact.parts))

src/a2a/utils/message.py

@@ -2,18 +2,13 @@
 
 import uuid
 
-from typing import Any
-
 from a2a.types import (
-    DataPart,
-    FilePart,
-    FileWithBytes,
-    FileWithUri,
     Message,
     Part,
     Role,
     TextPart,
 )
+from a2a.utils.parts import get_text_parts
 
 
 def new_agent_text_message(
@@ -64,42 +59,6 @@ def new_agent_parts_message(
     )
 
 
-def get_text_parts(parts: list[Part]) -> list[str]:
-    """Extracts text content from all TextPart objects in a list of Parts.
-
-    Args:
-        parts: A list of `Part` objects.
-
-    Returns:
-        A list of strings containing the text content from any `TextPart` objects found.
-    """
-    return [part.root.text for part in parts if isinstance(part.root, TextPart)]
-
-
-def get_data_parts(parts: list[Part]) -> list[dict[str, Any]]:
-    """Extracts dictionary data from all DataPart objects in a list of Parts.
-
-    Args:
-        parts: A list of `Part` objects.
-
-    Returns:
-        A list of dictionaries containing the data from any `DataPart` objects found.
-    """
-    return [part.root.data for part in parts if isinstance(part.root, DataPart)]
-
-
-def get_file_parts(parts: list[Part]) -> list[FileWithBytes | FileWithUri]:
-    """Extracts file data from all FilePart objects in a list of Parts.
-
-    Args:
-        parts: A list of `Part` objects.
-
-    Returns:
-        A list of `FileWithBytes` or `FileWithUri` objects containing the file data from any `FilePart` objects found.
-    """
-    return [part.root.file for part in parts if isinstance(part.root, FilePart)]
-
-
 def get_message_text(message: Message, delimiter: str = '\n') -> str:
     """Extracts and joins all text content from a Message's parts.
 

src/a2a/utils/parts.py

@@ -0,0 +1,48 @@
+"""Utility functions for creating and handling A2A Parts objects."""
+
+from typing import Any
+
+from a2a.types import (
+    DataPart,
+    FilePart,
+    FileWithBytes,
+    FileWithUri,
+    Part,
+    TextPart,
+)
+
+
+def get_text_parts(parts: list[Part]) -> list[str]:
+    """Extracts text content from all TextPart objects in a list of Parts.
+
+    Args:
+        parts: A list of `Part` objects.
+
+    Returns:
+        A list of strings containing the text content from any `TextPart` objects found.
+    """
+    return [part.root.text for part in parts if isinstance(part.root, TextPart)]
+
+
+def get_data_parts(parts: list[Part]) -> list[dict[str, Any]]:
+    """Extracts dictionary data from all DataPart objects in a list of Parts.
+
+    Args:
+        parts: A list of `Part` objects.
+
+    Returns:
+        A list of dictionaries containing the data from any `DataPart` objects found.
+    """
+    return [part.root.data for part in parts if isinstance(part.root, DataPart)]
+
+
+def get_file_parts(parts: list[Part]) -> list[FileWithBytes | FileWithUri]:
+    """Extracts file data from all FilePart objects in a list of Parts.
+
+    Args:
+        parts: A list of `Part` objects.
+
+    Returns:
+        A list of `FileWithBytes` or `FileWithUri` objects containing the file data from any `FilePart` objects found.
+    """
+    return [part.root.file for part in parts if isinstance(part.root, FilePart)]

tests/server/apps/jsonrpc/test_serialization.py

@@ -122,30 +122,18 @@ def test_handle_oversized_payload(agent_card_with_api_key: AgentCard):
     app_instance = A2AStarletteApplication(agent_card_with_api_key, handler)
     client = TestClient(app_instance.build())
 
-    large_string = 'a' * 2_000_000  # 2MB string
+    large_string = 'a' * 11 * 1_000_000  # 11MB string
     payload = {
         'jsonrpc': '2.0',
         'method': 'test',
         'id': 1,
         'params': {'data': large_string},
     }
 
-    # Starlette/FastAPI's default max request size is around 1MB.
-    # This test will likely fail with a 413 Payload Too Large if the default is not increased.
-    # If the application is expected to handle larger payloads, the server configuration needs to be adjusted.
-    # For this test, we expect a 413 or a graceful JSON-RPC error if the app handles it.
-
-    try:
-        response = client.post('/', json=payload)
-        # If the app handles it gracefully and returns a JSON-RPC error
-        if response.status_code == 200:
-            data = response.json()
-            assert data['error']['code'] == InvalidRequestError().code
-        else:
-            assert response.status_code == 413
-    except Exception as e:
-        # Depending on server setup, it might just drop the connection for very large payloads
-        assert isinstance(e, ConnectionResetError | RuntimeError)
+    response = client.post('/', json=payload)
+    assert response.status_code == 200
+    data = response.json()
+    assert data['error']['code'] == InvalidRequestError().code
 
 
 def test_handle_unicode_characters(agent_card_with_api_key: AgentCard):

tests/utils/test_artifact.py

@@ -3,8 +3,14 @@
 
 from unittest.mock import patch
 
-from a2a.types import DataPart, Part, TextPart
+from a2a.types import (
+    Artifact,
+    DataPart,
+    Part,
+    TextPart,
+)
 from a2a.utils.artifact import (
+    get_artifact_text,
     new_artifact,
     new_data_artifact,
     new_text_artifact,
@@ -32,7 +38,7 @@ def test_new_artifact_empty_description_if_not_provided(self):
         parts = [Part(root=TextPart(text='Another sample'))]
         name = 'Artifact_No_Desc'
         artifact = new_artifact(parts=parts, name=name)
-        self.assertEqual(artifact.description, '')
+        self.assertEqual(artifact.description, None)
 
     def test_new_text_artifact_creates_single_text_part(self):
         text = 'This is a text artifact.'
@@ -83,5 +89,71 @@ def test_new_data_artifact_assigns_name_description(self):
         self.assertEqual(artifact.description, description)
 
 
+class TestGetArtifactText(unittest.TestCase):
+    def test_get_artifact_text_single_part(self):
+        # Setup
+        artifact = Artifact(
+            name='test-artifact',
+            parts=[Part(root=TextPart(text='Hello world'))],
+            artifact_id='test-artifact-id',
+        )
+
+        # Exercise
+        result = get_artifact_text(artifact)
+
+        # Verify
+        assert result == 'Hello world'
+
+    def test_get_artifact_text_multiple_parts(self):
+        # Setup
+        artifact = Artifact(
+            name='test-artifact',
+            parts=[
+                Part(root=TextPart(text='First line')),
+                Part(root=TextPart(text='Second line')),
+                Part(root=TextPart(text='Third line')),
+            ],
+            artifact_id='test-artifact-id',
+        )
+
+        # Exercise
+        result = get_artifact_text(artifact)
+
+        # Verify - default delimiter is newline
+        assert result == 'First line\nSecond line\nThird line'
+
+    def test_get_artifact_text_custom_delimiter(self):
+        # Setup
+        artifact = Artifact(
+            name='test-artifact',
+            parts=[
+                Part(root=TextPart(text='First part')),
+                Part(root=TextPart(text='Second part')),
+                Part(root=TextPart(text='Third part')),
+            ],
+            artifact_id='test-artifact-id',
+        )
+
+        # Exercise
+        result = get_artifact_text(artifact, delimiter=' | ')
+
+        # Verify
+        assert result == 'First part | Second part | Third part'
+
+    def test_get_artifact_text_empty_parts(self):
+        # Setup
+        artifact = Artifact(
+            name='test-artifact',
+            parts=[],
+            artifact_id='test-artifact-id',
+        )
+
+        # Exercise
+        result = get_artifact_text(artifact)
+
+        # Verify
+        assert result == ''
+
+
 if __name__ == '__main__':
     unittest.main()