Style: format code with black

agenta-backend/agenta_backend/services/llm_apps_service.py

@@ -219,9 +219,9 @@ async def batch_invoke(
         "delay_between_batches"
     ]  # Delay between batches (in seconds)
 
-    list_of_app_outputs: List[
-        InvokationResult
-    ] = []  # Outputs after running all batches
+    list_of_app_outputs: List[InvokationResult] = (
+        []
+    )  # Outputs after running all batches
     openapi_parameters = await get_parameters_from_openapi(uri + "/openapi.json")
 
     async def run_batch(start_idx: int):

agenta-cli/agenta/client/backend/client.py

@@ -56,9 +56,9 @@ def __init__(
         self._client_wrapper = SyncClientWrapper(
             base_url=base_url,
             api_key=api_key,
-            httpx_client=httpx.Client(timeout=timeout)
-            if httpx_client is None
-            else httpx_client,
+            httpx_client=(
+                httpx.Client(timeout=timeout) if httpx_client is None else httpx_client
+            ),
         )
         self.observability = ObservabilityClient(client_wrapper=self._client_wrapper)
         self.apps = AppsClient(client_wrapper=self._client_wrapper)
@@ -1037,9 +1037,11 @@ def __init__(
         self._client_wrapper = AsyncClientWrapper(
             base_url=base_url,
             api_key=api_key,
-            httpx_client=httpx.AsyncClient(timeout=timeout)
-            if httpx_client is None
-            else httpx_client,
+            httpx_client=(
+                httpx.AsyncClient(timeout=timeout)
+                if httpx_client is None
+                else httpx_client
+            ),
         )
         self.observability = AsyncObservabilityClient(
             client_wrapper=self._client_wrapper

agenta-cli/agenta/sdk/decorators/tracing.py

@@ -12,6 +12,7 @@
 # Set global tracing variable to None
 tracing = None
 
+
 class instrument(BaseDecorator):
     """Decorator class for monitoring llm apps functions.
 

agenta-cli/agenta/sdk/tracing/context_manager.py

@@ -3,11 +3,8 @@
 
 
 class TracingContextManager:
-    def __init__(self, tracing: Tracing):
-        ...
+    def __init__(self, tracing: Tracing): ...
 
-    def __enter__(self):
-        ...
+    def __enter__(self): ...
 
-    def __exit__(self, exc_type, exc_val, exc_tb):
-        ...
+    def __exit__(self, exc_type, exc_val, exc_tb): ...

agenta-cli/agenta/sdk/tracing/llm_tracing.py

@@ -163,8 +163,10 @@ def start_span(
             self.active_span = span
             self.active_span = span
             self.span_dict[span.id] = span
-            span.parent_span_id = self.parent_span_id # set the parent_span_id to the present span
-            self.parent_span_id = span.id # update parent_span_id to active span
+            span.parent_span_id = (
+                self.parent_span_id
+            )  # set the parent_span_id to the present span
+            self.parent_span_id = span.id  # update parent_span_id to active span
 
         self.llm_logger.info(f"Recorded span and setting parent_span_id: {span.id}")
         return span

examples/app_with_observability/workflows/tracing_from_hosted.py

@@ -14,6 +14,7 @@
 )
 llm_config = {"environment": "production"}
 
+
 def hosted_platform_call(content: str):
     span = tracing.start_span(
         name="gpt3.5-llm-call",