linter

Author: ahoblitz

src/a2a/client/card_resolver.py

@@ -71,7 +71,7 @@ async def get_agent_card(
         else:
             path_segment = relative_card_path.lstrip('/')
 
-        target_url = '{}/{}'.format(self.base_url, path_segment)
+        target_url = f'{self.base_url}/{path_segment}'
 
         try:
             response = await self.httpx_client.get(

src/a2a/client/transports/rest.py

@@ -135,7 +135,7 @@ async def send_message_streaming(
         async with aconnect_sse(
             self.httpx_client,
             'POST',
-            '{}/v1/message:stream'.format(self.url),
+            f'{self.url}/v1/message:stream',
             json=payload,
             **modified_kwargs,
         ) as event_source:
@@ -178,7 +178,7 @@ async def _send_post_request(
         return await self._send_request(
             self.httpx_client.build_request(
                 'POST',
-                '{}{}'.format(self.url, target),
+                f'{self.url}{target}',
                 json=rpc_request_payload,
                 **(http_kwargs or {}),
             )
@@ -193,7 +193,7 @@ async def _send_get_request(
         return await self._send_request(
             self.httpx_client.build_request(
                 'GET',
-                '{}{}'.format(self.url, target),
+                f'{self.url}{target}',
                 params=query_params,
                 **(http_kwargs or {}),
             )
@@ -308,7 +308,7 @@ async def resubscribe(
         async with aconnect_sse(
             self.httpx_client,
             'GET',
-            '{}/v1/tasks/{}:subscribe'.format(self.url, request.id),
+            f'{self.url}/v1/tasks/{request.id}:subscribe',
             **http_kwargs,
         ) as event_source:
             try:

src/a2a/server/apps/rest/fastapi_app.py

@@ -108,10 +108,10 @@ def build(
         router = APIRouter()
         for route, callback in self._adapter.routes().items():
             router.add_api_route(
-                '{}{}'.format(rpc_url, route[0]), callback, methods=[route[1]]
+                f'{rpc_url}{route[0]}', callback, methods=[route[1]]
             )
 
-        @router.get('{}{}'.format(rpc_url, agent_card_url))
+        @router.get(f'{rpc_url}{agent_card_url}')
         async def get_agent_card(request: Request) -> Response:
             card = await self._adapter.handle_get_agent_card(request)
             return JSONResponse(card)

src/a2a/utils/telemetry.py

@@ -166,9 +166,7 @@ def trace_function(  # noqa: PLR0915
             attribute_extractor=attribute_extractor,
         )
 
-    actual_span_name = span_name or '{}.{}'.format(
-        func.__module__, func.__name__
-    )
+    actual_span_name = span_name or f'{func.__module__}.{func.__name__}'
 
     is_async_func = inspect.iscoroutinefunction(func)
 
@@ -325,7 +323,7 @@ def decorator(cls: Any) -> Any:
             if not include_list and name in exclude_list:
                 continue
 
-            span_name = '{}.{}.{}'.format(cls.__module__, cls.__name__, name)
+            span_name = f'{cls.__module__}.{cls.__name__}.{name}'
             setattr(
                 cls,
                 name,