autoformat

Author: eberki-scale

src/agentex/lib/core/clients/temporal/temporal_client.py

@@ -77,7 +77,9 @@
 
 
 class TemporalClient:
-    def __init__(self, temporal_client: Client | None = None, plugins: list[Any] = [], payload_codec: PayloadCodec | None = None):
+    def __init__(
+        self, temporal_client: Client | None = None, plugins: list[Any] = [], payload_codec: PayloadCodec | None = None
+    ):
         self._client: Client | None = temporal_client
         self._plugins = plugins
         self._payload_codec = payload_codec

src/agentex/lib/core/clients/temporal/utils.py

@@ -1,13 +1,12 @@
 from __future__ import annotations
 
-from typing import Any
-
 import dataclasses
+from typing import Any
 
 from temporalio.client import Client, Plugin as ClientPlugin
-from temporalio.converter import PayloadCodec
 from temporalio.worker import Interceptor
 from temporalio.runtime import Runtime, TelemetryConfig, OpenTelemetryConfig
+from temporalio.converter import PayloadCodec
 from temporalio.contrib.pydantic import pydantic_data_converter
 
 # class DateTimeJSONEncoder(AdvancedJSONEncoder):
@@ -107,9 +106,8 @@ async def get_temporal_client(
     # Check if OpenAI plugin is present - it needs to configure its own data converter
     # Lazy import to avoid pulling in opentelemetry.sdk for non-Temporal agents
     from temporalio.contrib.openai_agents import OpenAIAgentsPlugin
-    has_openai_plugin = any(
-        isinstance(p, OpenAIAgentsPlugin) for p in (plugins or [])
-    )
+
+    has_openai_plugin = any(isinstance(p, OpenAIAgentsPlugin) for p in (plugins or []))
 
     # Only set data_converter if OpenAI plugin is not present
     connect_kwargs = {

src/agentex/lib/core/temporal/workers/worker.py

@@ -18,8 +18,8 @@
 )
 from temporalio.runtime import Runtime, TelemetryConfig, OpenTelemetryConfig
 from temporalio.converter import (
-    DataConverter,
     PayloadCodec,
+    DataConverter,
     JSONTypeConverter,
     AdvancedJSONEncoder,
     DefaultPayloadConverter,
@@ -102,9 +102,8 @@ async def get_temporal_client(
     # Check if OpenAI plugin is present - it needs to configure its own data converter
     # Lazy import to avoid pulling in opentelemetry.sdk for non-Temporal agents
     from temporalio.contrib.openai_agents import OpenAIAgentsPlugin
-    has_openai_plugin = any(
-        isinstance(p, OpenAIAgentsPlugin) for p in (plugins or [])
-    )
+
+    has_openai_plugin = any(isinstance(p, OpenAIAgentsPlugin) for p in (plugins or []))
 
     # Build connection kwargs
     connect_kwargs = {
@@ -146,7 +145,9 @@ def __init__(
         self.max_concurrent_activities = max_concurrent_activities
         self.health_check_server_running = False
         self.healthy = False
-        self.health_check_port = health_check_port if health_check_port is not None else EnvironmentVariables.refresh().HEALTH_CHECK_PORT
+        self.health_check_port = (
+            health_check_port if health_check_port is not None else EnvironmentVariables.refresh().HEALTH_CHECK_PORT
+        )
         self.plugins = plugins
         self.interceptors = interceptors
         self.metrics_url = metrics_url

src/agentex/lib/sdk/fastacp/fastacp.py

@@ -34,7 +34,7 @@ class FastACP:
     Supports three main ACP types:
     - "sync": Simple synchronous ACP implementation
     - "async": Advanced ACP with sub-types "base" or "temporal" (requires config)
-    - "agentic": (Deprecated, use "async") Identical to "async" 
+    - "agentic": (Deprecated, use "async") Identical to "async"
     """
 
     @staticmethod

src/agentex/lib/sdk/fastacp/impl/temporal_acp.py

@@ -43,11 +43,19 @@ def __init__(
 
     @classmethod
     @override
-    def create(cls, temporal_address: str, plugins: list[Any] | None = None, interceptors: list[Any] | None = None, payload_codec: PayloadCodec | None = None) -> "TemporalACP":
+    def create(
+        cls,
+        temporal_address: str,
+        plugins: list[Any] | None = None,
+        interceptors: list[Any] | None = None,
+        payload_codec: PayloadCodec | None = None,
+    ) -> "TemporalACP":
         logger.info("Initializing TemporalACP instance")
 
         # Create instance without temporal client initially
-        temporal_acp = cls(temporal_address=temporal_address, plugins=plugins, interceptors=interceptors, payload_codec=payload_codec)
+        temporal_acp = cls(
+            temporal_address=temporal_address, plugins=plugins, interceptors=interceptors, payload_codec=payload_codec
+        )
         temporal_acp._setup_handlers()
         logger.info("TemporalACP instance initialized now")
         return temporal_acp

src/agentex/lib/types/fastacp.py

@@ -39,8 +39,10 @@ class AsyncACPConfig(BaseACPConfig):
 
     type: Literal["temporal", "base"] = Field(..., frozen=True)
 
+
 AgenticACPConfig = AsyncACPConfig
 
+
 class TemporalACPConfig(AsyncACPConfig):
     """
     Configuration for TemporalACP implementation
@@ -87,4 +89,5 @@ class AsyncBaseACPConfig(AsyncACPConfig):
 
     type: Literal["base"] = Field(default="base", frozen=True)
 
-AgenticBaseACPConfig = AsyncBaseACPConfig
+
+AgenticBaseACPConfig = AsyncBaseACPConfig