Merge branch 'snake-case-field' of https://github.com/google-a2a/a2a-python into snake-case-field

Author: holtskinner

CHANGELOG.md

@@ -1,5 +1,13 @@
 # Changelog
 
+## [0.2.15](https://github.com/a2aproject/a2a-python/compare/v0.2.14...v0.2.15) (2025-07-21)
+
+
+### Bug Fixes
+
+* Add Input Validation for Empty Message Content ([#327](https://github.com/a2aproject/a2a-python/issues/327)) ([5061834](https://github.com/a2aproject/a2a-python/commit/5061834e112a4eb523ac505f9176fc42d86d8178))
+* Prevent import grpc issues for Client after making dependencies optional ([#330](https://github.com/a2aproject/a2a-python/issues/330)) ([53ad485](https://github.com/a2aproject/a2a-python/commit/53ad48530b47ef1cbd3f40d0432f9170b663839d)), closes [#326](https://github.com/a2aproject/a2a-python/issues/326)
+
 ## [0.2.14](https://github.com/a2aproject/a2a-python/compare/v0.2.13...v0.2.14) (2025-07-18)
 
 

src/a2a/client/__init__.py

@@ -1,5 +1,7 @@
 """Client-side components for interacting with an A2A agent."""
 
+import logging
+
 from a2a.client.auth import (
     AuthInterceptor,
     CredentialService,
@@ -12,11 +14,31 @@
     A2AClientJSONError,
     A2AClientTimeoutError,
 )
-from a2a.client.grpc_client import A2AGrpcClient
 from a2a.client.helpers import create_text_message_object
 from a2a.client.middleware import ClientCallContext, ClientCallInterceptor
 
 
+logger = logging.getLogger(__name__)
+
+try:
+    from a2a.client.grpc_client import A2AGrpcClient  # type: ignore
+except ImportError as e:
+    _original_error = e
+    logger.debug(
+        'A2AGrpcClient not loaded. This is expected if gRPC dependencies are not installed. Error: %s',
+        _original_error,
+    )
+
+    class A2AGrpcClient:  # type: ignore
+        """Placeholder for A2AGrpcClient when dependencies are not installed."""
+
+        def __init__(self, *args, **kwargs):
+            raise ImportError(
+                'To use A2AGrpcClient, its dependencies must be installed. '
+                'You can install them with \'pip install "a2a-sdk[grpc]"\''
+            ) from _original_error
+
+
 __all__ = [
     'A2ACardResolver',
     'A2AClient',

src/a2a/client/grpc_client.py

@@ -2,7 +2,16 @@
 
 from collections.abc import AsyncGenerator
 
-import grpc
+
+try:
+    import grpc
+except ImportError as e:
+    raise ImportError(
+        'A2AGrpcClient requires grpcio and grpcio-tools to be installed. '
+        'Install with: '
+        "'pip install a2a-sdk[grpc]'"
+    ) from e
+
 
 from a2a.grpc import a2a_pb2, a2a_pb2_grpc
 from a2a.types import (

src/a2a/server/request_handlers/__init__.py

@@ -23,6 +23,7 @@
     _original_error = e
     logger.debug(
         'GrpcHandler not loaded. This is expected if gRPC dependencies are not installed. Error: %s',
+        _original_error,
     )
 
     class GrpcHandler:  # type: ignore

src/a2a/utils/task.py

@@ -2,7 +2,7 @@
 
 import uuid
 
-from a2a.types import Artifact, Message, Task, TaskState, TaskStatus
+from a2a.types import Artifact, Message, Task, TaskState, TaskStatus, TextPart
 
 
 def new_task(request: Message) -> Task:
@@ -18,12 +18,15 @@ def new_task(request: Message) -> Task:
 
     Raises:
         TypeError: If the message role is None.
-        ValueError: If the message parts are empty.
+        ValueError: If the message parts are empty or if any part has empty content.
     """
     if not request.role:
         raise TypeError('Message role cannot be None')
     if not request.parts:
         raise ValueError('Message parts cannot be empty')
+    for part in request.parts:
+        if isinstance(part.root, TextPart) and not part.root.text:
+            raise ValueError('TextPart content cannot be empty')
 
     return Task(
         status=TaskStatus(state=TaskState.submitted),

tests/utils/test_task.py

@@ -145,6 +145,16 @@ def test_new_task_invalid_message_empty_parts(self):
                 )
             )
 
+    def test_new_task_invalid_message_empty_content(self):
+        with self.assertRaises(ValueError):
+            new_task(
+                Message(
+                    role=Role.user,
+                    parts=[Part(root=TextPart(text=''))],
+                    messageId=str(uuid.uuid4()),
+                )
+            )
+
     def test_new_task_invalid_message_none_role(self):
         with self.assertRaises(TypeError):
             msg = Message.model_construct(