style: apply auto-formatting

Author: theailifestyle

.github/actions/spelling/allow.txt

@@ -3,53 +3,58 @@ AClient
 AError
 ARequest
 ARun
+ASGI
 AServer
 AServers
 AStarlette
 EUR
 GBP
+GPT
 INR
 JPY
 JSONRPCt
+LLMs
 Llm
 aconnect
 adk
 agentic
 autouse
+avanc
+avancées
 cla
 cls
 coc
 codegen
 coro
+dans
 datamodel
+derni
+dernières
+docstrings
 dunders
 genai
 gle
+gpt
 inmemory
 kwarg
+l'actualit
+l'actualité
 langgraph
 lifecycles
 linting
+llm
+m'appelle
+mcp
+mundo
+npx
 oauthoidc
 opensource
 pyversions
+résultats
 socio
 sse
+sultats
 tagwords
+thiques
 vulnz
-ASGI
-avancées
-dans
-dernières
-docstrings
-GPT
-gpt
-l'actualité
-llm
-LLMs
-m'appelle
-mcp
-mundo
-npx
-résultats
 éthiques

.vscode/settings.json

@@ -1,5 +1,7 @@
 {
-  "python.testing.pytestArgs": ["tests"],
+  "python.testing.pytestArgs": [
+    "tests"
+  ],
   "python.testing.unittestEnabled": false,
   "python.testing.pytestEnabled": true,
   "editor.formatOnSave": true,
@@ -11,4 +13,4 @@
     }
   },
   "ruff.importStrategy": "fromEnvironment"
-}
+}

examples/google_adk/french_translation_agent/__main__.py

@@ -1,21 +1,17 @@
-import asyncio
-import functools
 import logging
 import os
-import sys
 
 import click
 import uvicorn
 
+from adk_agent_executor import ADKFrenchTranslationAgentExecutor
 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.types import AgentCapabilities, AgentCard, AgentSkill
 
-from adk_agent_executor import ADKFrenchTranslationAgentExecutor
-
 
 load_dotenv()
 
@@ -30,7 +26,9 @@
 def main(host: str, port: int):
     # Ensure GOOGLE_API_KEY is set for the Gemini model used by this agent.
     if not os.getenv('GOOGLE_API_KEY'):
-        logger.error('GOOGLE_API_KEY environment variable not set. This agent may not function correctly.')
+        logger.error(
+            'GOOGLE_API_KEY environment variable not set. This agent may not function correctly.'
+        )
 
     # Define the capabilities and skills of this French Translation Agent.
     skill = AgentSkill(
@@ -53,15 +51,19 @@ def main(host: str, port: int):
         defaultInputModes=['text'],
         defaultOutputModes=['text'],
         capabilities=AgentCapabilities(streaming=True),
-        skills=[skill]
+        skills=[skill],
     )
     request_handler = DefaultRequestHandler(
         agent_executor=agent_executor, task_store=InMemoryTaskStore()
     )
     app = A2AStarletteApplication(agent_card, request_handler)
 
-    logger.info(f"Starting French Translation Agent server on http://{host}:{port}")
-    logger.info(f"This agent is identified by 'french_translator' for delegation.")
+    logger.info(
+        f'Starting French Translation Agent server on http://{host}:{port}'
+    )
+    logger.info(
+        "This agent is identified by 'french_translator' for delegation."
+    )
     uvicorn.run(app.build(), host=host, port=port)
 
 

examples/google_adk/french_translation_agent/adk_agent.py

@@ -1,11 +1,15 @@
 import os
+
 from google.adk.agents import LlmAgent
 
+
 async def create_french_translation_agent() -> LlmAgent:
     """Constructs the ADK French Translation agent."""
     # Ensure GOOGLE_API_KEY is set for Gemini model usage.
-    if not os.getenv("GOOGLE_API_KEY"):
-        print("Warning: GOOGLE_API_KEY environment variable not set. This agent may not function correctly.")
+    if not os.getenv('GOOGLE_API_KEY'):
+        print(
+            'Warning: GOOGLE_API_KEY environment variable not set. This agent may not function correctly.'
+        )
 
     return LlmAgent(
         model='gemini-1.5-flash',

examples/google_adk/french_translation_agent/adk_agent_executor.py

@@ -3,19 +3,15 @@
 import logging
 
 from collections.abc import AsyncGenerator, AsyncIterable
-from typing import Any
-from uuid import uuid4
 
+from adk_agent import create_french_translation_agent
 from google.adk import Runner
-from google.adk.agents import LlmAgent, RunConfig
 from google.adk.artifacts import InMemoryArtifactService
 from google.adk.events import Event
 from google.adk.memory.in_memory_memory_service import InMemoryMemoryService
 from google.adk.sessions import InMemorySessionService
 from google.genai import types as genai_types
-from pydantic import ConfigDict
 
-from a2a.client import A2AClient
 from a2a.server.agent_execution import AgentExecutor, RequestContext
 from a2a.server.events.event_queue import EventQueue
 from a2a.server.tasks import TaskUpdater
@@ -24,26 +20,14 @@
     FilePart,
     FileWithBytes,
     FileWithUri,
-    GetTaskRequest,
-    GetTaskSuccessResponse,
-    Message,
-    MessageSendParams,
     Part,
-    Role,
-    SendMessageRequest,
-    SendMessageSuccessResponse,
-    Task,
-    TaskQueryParams,
     TaskState,
     TaskStatus,
     TextPart,
     UnsupportedOperationError,
 )
-from a2a.utils import get_text_parts
 from a2a.utils.errors import ServerError
 
-from adk_agent import create_french_translation_agent
-
 
 logger = logging.getLogger(__name__)
 logger.setLevel(logging.DEBUG)
@@ -67,12 +51,12 @@ def _run_agent(
         self,
         session_id: str,
         new_message: genai_types.Content,
-        task_updater: TaskUpdater, # This parameter is not used in this method.
+        task_updater: TaskUpdater,  # This parameter is not used in this method.
     ) -> AsyncGenerator[Event, None]:
         """Runs the ADK agent with the given message."""
         return self.runner.run_async(
             session_id=session_id,
-            user_id='self', # The user ID for the ADK session.
+            user_id='self',  # The user ID for the ADK session.
             new_message=new_message,
         )
 
@@ -88,7 +72,9 @@ async def _process_request(
         )
         session_id = session.id
         async for event in self._run_agent(
-            session_id, new_message, task_updater # Pass task_updater to _run_agent
+            session_id,
+            new_message,
+            task_updater,  # Pass task_updater to _run_agent
         ):
             logger.debug('Received ADK event: %s', event)
             if event.is_final_response():
@@ -98,7 +84,7 @@ async def _process_request(
                 task_updater.add_artifact(response)
                 task_updater.complete()
                 break
-            elif not event.get_function_calls():
+            if not event.get_function_calls():
                 # If it's not a final response and no function calls, it's an interim update.
                 logger.debug('Yielding update response')
                 task_updater.update_status(
@@ -109,8 +95,10 @@ async def _process_request(
                 )
             else:
                 # This agent does not use tools, so function calls are unexpected.
-                logger.debug('Skipping event with function call: %s', event.get_function_calls())
-
+                logger.debug(
+                    'Skipping event with function call: %s',
+                    event.get_function_calls(),
+                )
 
     async def execute(
         self,

examples/google_adk/mcp_brave_search_agent/__main__.py

@@ -1,21 +1,18 @@
-import asyncio
-import functools
 import logging
 import os
 import sys
 
 import click
 import uvicorn
 
+from adk_agent_executor import ADKBraveSearchAgentExecutor
 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.types import AgentCapabilities, AgentCard, AgentSkill
 
-from adk_agent_executor import ADKBraveSearchAgentExecutor
-
 
 load_dotenv()
 
@@ -28,7 +25,9 @@
 def main(host: str, port: int):
     # Ensure BRAVE_API_KEY is set for the Brave Search MCP server.
     if not os.getenv('BRAVE_API_KEY'):
-        print('BRAVE_API_KEY environment variable not set. This agent requires it to function.')
+        print(
+            'BRAVE_API_KEY environment variable not set. This agent requires it to function.'
+        )
         sys.exit(1)
 
     # Define the capabilities and skills of this Brave Search Agent.

examples/google_adk/mcp_brave_search_agent/adk_agent.py

@@ -1,12 +1,19 @@
 import os
+
 from google.adk.agents import LlmAgent
-from google.adk.tools.mcp_tool.mcp_toolset import MCPToolset, StdioServerParameters
+from google.adk.tools.mcp_tool.mcp_toolset import (
+    MCPToolset,
+    StdioServerParameters,
+)
+
 
 async def create_mcp_brave_search_agent() -> LlmAgent:
     """Constructs the ADK MCP Brave Search agent."""
-    brave_api_key = os.getenv("BRAVE_API_KEY")
+    brave_api_key = os.getenv('BRAVE_API_KEY')
     if not brave_api_key:
-        raise ValueError("BRAVE_API_KEY environment variable not set. This agent requires it.")
+        raise ValueError(
+            'BRAVE_API_KEY environment variable not set. This agent requires it.'
+        )
 
     return LlmAgent(
         model='gemini-2.0-flash',
@@ -24,12 +31,10 @@ async def create_mcp_brave_search_agent() -> LlmAgent:
                 connection_params=StdioServerParameters(
                     command='npx',
                     args=[
-                        "-y",
-                        "@modelcontextprotocol/server-brave-search",
+                        '-y',
+                        '@modelcontextprotocol/server-brave-search',
                     ],
-                    env={
-                        "BRAVE_API_KEY": brave_api_key
-                    }
+                    env={'BRAVE_API_KEY': brave_api_key},
                 ),
             )
         ],