fix(typos): fix history file typos

fix(typos): fix history file typos

Author: yaozheng-fang

02-use-cases/ai_coding/agent.py

@@ -43,12 +43,16 @@
 
 tracer = OpentelemetryTracer(exporters=[APMPlusExporter()])
 
-with open('%s/prompt.zh.md'%current_dir, 'r', encoding='utf-8') as f:
+with open("%s/prompt.zh.md" % current_dir, "r", encoding="utf-8") as f:
     instruction = f.read()
 root_agent = Agent(
     description="An AI coding agent that helps users solve programming problems",
     instruction=instruction,
-    tools=[run_code, upload_frontend_code_to_tos, get_url_of_frontend_code_in_tos],
+    tools=[
+        run_code,
+        upload_frontend_code_to_tos,
+        get_url_of_frontend_code_in_tos,
+    ],
     tracers=[tracer],
     short_term_memory=short_term_memory,
     planner=BuiltInPlanner(
@@ -57,16 +61,17 @@
             thinking_budget=1024,
         )
     ),
-    model_name='deepseek-v3-1-terminus'
-
+    model_name="deepseek-v3-1-terminus",
 )
 
 app_name = "ai_coding_agent"
-runner = Runner(app_name=app_name, agent=root_agent, short_term_memory=short_term_memory)
-
-agent_server_app = AgentkitAgentServerApp(agent=root_agent, short_term_memory=short_term_memory)
-
+runner = Runner(
+    app_name=app_name, agent=root_agent, short_term_memory=short_term_memory
+)
 
+agent_server_app = AgentkitAgentServerApp(
+    agent=root_agent, short_term_memory=short_term_memory
+)
 
 
 if __name__ == "__main__":

02-use-cases/ai_coding/tools.py

@@ -10,6 +10,7 @@
 
 client: tos.TosClientV2 = None
 
+
 def _init_tos_client():
     global client
     if client is not None:
@@ -27,8 +28,13 @@ def _init_tos_client():
         sk = cred.secret_access_key
         security_token = cred.session_token
 
-    client = tos.TosClientV2(ak=ak, sk=sk, security_token=security_token,
-                             endpoint=f"tos-{region}.volces.com", region=region)
+    client = tos.TosClientV2(
+        ak=ak,
+        sk=sk,
+        security_token=security_token,
+        endpoint=f"tos-{region}.volces.com",
+        region=region,
+    )
 
 
 def upload_frontend_code_to_tos(code: str, code_type: str) -> str:
@@ -65,7 +71,7 @@ def upload_frontend_code_to_tos(code: str, code_type: str) -> str:
         resp = client.put_object(
             bucket_name,
             object_key,
-            content=code.encode('utf-8'),
+            content=code.encode("utf-8"),
             acl=tos.ACLType.ACL_Public_Read,
         )
         if resp.status_code == 200:

02-use-cases/beginner/a2a_simple/agent.py

@@ -1,18 +1,20 @@
-from veadk import Agent, Runner
-from veadk.a2a.remote_ve_agent import RemoteVeAgent
+from a2a.types import AgentCapabilities, AgentCard, AgentProvider, AgentSkill
 from agentkit.apps import AgentkitA2aApp
 from google.adk.a2a.executor.a2a_agent_executor import A2aAgentExecutor
-from a2a.types import AgentCard, AgentProvider, AgentSkill, AgentCapabilities
+from veadk import Agent, Runner
+from veadk.a2a.remote_ve_agent import RemoteVeAgent
 
 remote_agent = RemoteVeAgent(
     name="a2a_agent",
     url="http://localhost:8001/",  # <--- url from remote agent service
 )
 
+
 def add(a: int, b: int) -> int:
     """Adds two numbers."""
     return a + b
 
+
 agent = Agent(
     name="a2a_sample_agent",
     instruction="You are a helpful assistant that can add numbers and delegate tasks to a remote agent that can roll dice and check prime numbers.",
@@ -25,17 +27,19 @@ def add(a: int, b: int) -> int:
 
 a2aApp = AgentkitA2aApp()
 
+
 @a2aApp.agent_executor(runner=runner)
 class MyAgentExecutor(A2aAgentExecutor):
     pass
 
+
 if __name__ == "__main__":
     agent_card = AgentCard(
         capabilities=AgentCapabilities(streaming=True),
         description=agent.description,
         name=agent.name,
-        defaultInputModes=["text"],
-        defaultOutputModes=["text"],
+        default_input_modes=["text"],
+        default_output_modes=["text"],
         provider=AgentProvider(organization="agentkit", url=""),
         skills=[AgentSkill(id="0", name="chat", description="Chat", tags=["chat"])],
         url="http://0.0.0.0:8000",
@@ -46,4 +50,4 @@ class MyAgentExecutor(A2aAgentExecutor):
         agent_card=agent_card,
         host="0.0.0.0",
         port=8000,
-    )
+    )

02-use-cases/beginner/a2a_simple/local_client.py

@@ -1,25 +1,21 @@
-import logging
-
-from typing import Any
-from uuid import uuid4
 import asyncio
-from a2a.client import ClientConfig, ClientFactory, create_text_message_object
-from a2a.types import TransportProtocol
-import agent
-import httpx
+from typing import Any
 
-from a2a.client import A2ACardResolver, A2AClient
+import httpx
+from a2a.client import (
+    ClientConfig,
+    ClientFactory,
+    create_text_message_object,
+)
 from a2a.types import (
     AgentCard,
-    MessageSendParams,
-    SendMessageRequest,
-    SendStreamingMessageRequest,
+    TransportProtocol,
 )
 from a2a.utils.constants import (
     AGENT_CARD_WELL_KNOWN_PATH,
-    EXTENDED_AGENT_CARD_PATH,
 )
 
+
 class A2ASimpleClient:
     """A2A Simple to call A2A servers."""
 
@@ -50,7 +46,7 @@ async def create_task(self, agent_url: str, message: str) -> str:
             else:
                 # Fetch the agent card
                 agent_card_response = await httpx_client.get(
-                    f'{agent_url}{AGENT_CARD_WELL_KNOWN_PATH}'
+                    f"{agent_url}{AGENT_CARD_WELL_KNOWN_PATH}"
                 )
                 agent_card_data = self._agent_info_cache[agent_url] = (
                     agent_card_response.json()
@@ -81,31 +77,28 @@ async def create_task(self, agent_url: str, message: str) -> str:
                 responses.append(response)
 
             # The response is a tuple - get the first element (Task object)
-            if (
-                responses
-                and isinstance(responses[0], tuple)
-                and len(responses[0]) > 0
-            ):
+            if responses and isinstance(responses[0], tuple) and len(responses[0]) > 0:
                 task = responses[0][0]  # First element of the tuple
-
                 # Extract text: task.artifacts[0].parts[0].root.text
                 try:
                     return task.artifacts[0].parts[0].root.text
                 except (AttributeError, IndexError):
                     return str(task)
 
-            return 'No response received'
+            return "No response received"
+
 
 a2a_client = A2ASimpleClient()
 
+
 async def test_trending_topics() -> None:
     """Test news topics agent."""
     for i in range(0, 10):
         trending_topics = await a2a_client.create_task(
-            f'http://localhost:8001', "hello , show me one number of 6-sided"
+            "http://localhost:8001", "hello , show me one number of 6-sided"
         )
         print(trending_topics)
 
 
 # Run the async function
-asyncio.run(test_trending_topics())     
+asyncio.run(test_trending_topics())

02-use-cases/beginner/a2a_simple/remote/agent.py

@@ -1,20 +1,15 @@
-import random
-
-from veadk import Agent, Runner
-from google.adk.a2a.utils.agent_to_a2a import to_a2a
-from google.adk.tools.tool_context import ToolContext
-from google.genai import types
+from a2a.types import AgentCapabilities, AgentCard, AgentProvider, AgentSkill
 from agentkit.apps import AgentkitA2aApp
-from tools.roll_die import roll_die
-from tools.check_prime import check_prime
-from a2a.types import AgentCard, AgentProvider, AgentCapabilities, AgentSkill
 from google.adk.a2a.executor.a2a_agent_executor import A2aAgentExecutor
+from tools.check_prime import check_prime
+from tools.roll_die import roll_die
+from veadk import Agent, Runner
 
 a2a_app = AgentkitA2aApp()
 root_agent = Agent(
-    name='hello_world_agent',
+    name="hello_world_agent",
     description=(
-        'hello world agent that can roll a dice of 8 sides and check prime numbers.'
+        "hello world agent that can roll a dice of 8 sides and check prime numbers."
     ),
     instruction="""
       You roll dice and answer questions about the outcome of the dice rolls.
@@ -36,29 +31,31 @@
     tools=[
         roll_die,
         check_prime,
-    ]
+    ],
 )
 
 runner = Runner(agent=root_agent)
 
+
 @a2a_app.agent_executor(runner=runner)
 class MyAgentExecutor(A2aAgentExecutor):
     pass
 
+
 agent_card = AgentCard(
-  capabilities=AgentCapabilities(streaming=True),
-  description=root_agent.description,
-  name=root_agent.name,
-  defaultInputModes=["text"],
-  defaultOutputModes=["text"],
-  provider=AgentProvider(organization="agentkit", url=""),
-  skills=[AgentSkill(id="0", name="chat", description="Chat", tags=["chat"])],
-  url="http://localhost:8001",
-  version="1.0.0",
+    capabilities=AgentCapabilities(streaming=True),
+    description=root_agent.description,
+    name=root_agent.name,
+    default_input_modes=["text"],
+    default_output_modes=["text"],
+    provider=AgentProvider(organization="agentkit", url=""),
+    skills=[AgentSkill(id="0", name="chat", description="Chat", tags=["chat"])],
+    url="http://localhost:8001",
+    version="1.0.0",
 )
 
-print('agent start successfully ', root_agent.name)
+print("agent start successfully ", root_agent.name)
 
 # a2a_app = to_a2a(root_agent, port=8001)
-if __name__ == '__main__':
-    a2a_app.run(agent_card=agent_card, host="0.0.0.0", port=8001)
+if __name__ == "__main__":
+    a2a_app.run(agent_card=agent_card, host="0.0.0.0", port=8001)

02-use-cases/beginner/a2a_simple/remote/tools/check_prime.py

@@ -1,26 +1,26 @@
 async def check_prime(nums: list[int]) -> str:
-  """Check if a given list of numbers are prime.
+    """Check if a given list of numbers are prime.
 
-  Args:
-    nums: The list of numbers to check.
+    Args:
+      nums: The list of numbers to check.
 
-  Returns:
-    A str indicating which number is prime.
-  """
-  primes = set()
-  for number in nums:
-    number = int(number)
-    if number <= 1:
-      continue
-    is_prime = True
-    for i in range(2, int(number**0.5) + 1):
-      if number % i == 0:
-        is_prime = False
-        break
-    if is_prime:
-      primes.add(number)
-  return (
-      'No prime numbers found.'
-      if not primes
-      else f"{', '.join(str(num) for num in primes)} are prime numbers."
-  )
+    Returns:
+      A str indicating which number is prime.
+    """
+    primes = set()
+    for number in nums:
+        number = int(number)
+        if number <= 1:
+            continue
+        is_prime = True
+        for i in range(2, int(number**0.5) + 1):
+            if number % i == 0:
+                is_prime = False
+                break
+        if is_prime:
+            primes.add(number)
+    return (
+        "No prime numbers found."
+        if not primes
+        else f"{', '.join(str(num) for num in primes)} are prime numbers."
+    )

02-use-cases/beginner/a2a_simple/remote/tools/roll_die.py

@@ -1,19 +1,21 @@
 import random
+
 from google.adk.tools.tool_context import ToolContext
 
+
 def roll_die(sides: int, tool_context: ToolContext) -> int:
-  """Roll a die and return the rolled result.
+    """Roll a die and return the rolled result.
 
-  Args:
-    sides: The integer number of sides the die has.
-    tool_context: the tool context
-  Returns:
-    An integer of the result of rolling the die.
-  """
-  result = random.randint(1, sides)
-  if not 'rolls' in tool_context.state:
-    tool_context.state['rolls'] = []
+    Args:
+      sides: The integer number of sides the die has.
+      tool_context: the tool context
+    Returns:
+      An integer of the result of rolling the die.
+    """
+    result = random.randint(1, sides)
+    if "rolls" not in tool_context.state:
+        tool_context.state["rolls"] = []
 
-  tool_context.state['rolls'] = tool_context.state['rolls'] + [result]
-  print(f"current round the result is {result}")
-  return result
+    tool_context.state["rolls"] = tool_context.state["rolls"] + [result]
+    print(f"current round the result is {result}")
+    return result

02-use-cases/beginner/callback/__init__.py

@@ -1 +1 @@
-from . import agent
+from . import agent  # noqa