refactor: cosmetic cleanup (a2aproject#906)

Author: ishymko

src/a2a/client/auth/interceptor.py

@@ -39,9 +39,7 @@ async def before(self, args: BeforeArgs) -> None:
                     scheme_name, args.context
                 )
                 if credential and scheme_name in agent_card.security_schemes:
-                    scheme = agent_card.security_schemes.get(scheme_name)
-                    if not scheme:
-                        continue
+                    scheme = agent_card.security_schemes[scheme_name]
 
                     if args.context is None:
                         args.context = ClientCallContext()

src/a2a/server/events/event_queue.py

@@ -243,5 +243,4 @@ async def clear_events(self, clear_child_queues: bool = True) -> None:
                 for child in self._children
             ]
 
-            if child_tasks:
-                await asyncio.gather(*child_tasks, return_exceptions=True)
+            await asyncio.gather(*child_tasks, return_exceptions=True)

src/a2a/server/request_handlers/grpc_handler.py

@@ -1,5 +1,4 @@
 # ruff: noqa: N802
-import contextlib
 import logging
 
 from abc import ABC, abstractmethod
@@ -74,9 +73,7 @@ class DefaultCallContextBuilder(CallContextBuilder):
     def build(self, context: grpc.aio.ServicerContext) -> ServerCallContext:
         """Builds the ServerCallContext."""
         user = UnauthenticatedUser()
-        state = {}
-        with contextlib.suppress(Exception):
-            state['grpc_context'] = context
+        state = {'grpc_context': context}
         return ServerCallContext(
             user=user,
             state=state,

src/a2a/server/routes/jsonrpc_dispatcher.py

@@ -1,6 +1,5 @@
 """JSON-RPC application for A2A server."""
 
-import contextlib
 import json
 import logging
 import traceback
@@ -154,7 +153,7 @@ def build(self, request: Request) -> ServerCallContext:
         """
         user: A2AUser = UnauthenticatedUser()
         state = {}
-        with contextlib.suppress(Exception):
+        if 'user' in request.scope:
             user = StarletteUserProxy(request.user)
             state['auth'] = request.auth
         state['headers'] = dict(request.headers)

src/a2a/utils/helpers.py

@@ -72,7 +72,7 @@ def append_artifact_to_task(task: Task, event: TaskArtifactUpdateEvent) -> None:
     """
     new_artifact_data: Artifact = event.artifact
     artifact_id: str = new_artifact_data.artifact_id
-    append_parts: bool = event.append or False
+    append_parts: bool = event.append
 
     existing_artifact: Artifact | None = None
     existing_artifact_list_index: int | None = None