Merge branch 'next' into stas/tracing-concurrent-egress

Author: smoreinis

.release-please-manifest.json

@@ -1,3 +1,3 @@
 {
-  ".": "0.11.4"
+  ".": "0.11.5"
 }

CHANGELOG.md

@@ -1,5 +1,29 @@
 # Changelog
 
+## 0.11.5 (2026-05-29)
+
+Full Changelog: [v0.11.4...v0.11.5](https://github.com/scaleapi/scale-agentex-python/compare/v0.11.4...v0.11.5)
+
+### Features
+
+* **api:** add cleaned_at field to task response types ([38ed338](https://github.com/scaleapi/scale-agentex-python/commit/38ed3384094f7f07f6b2482489f457fd1dc4f76d))
+* **deps:** bump openai-agents to >=0.14.3 for scale-sandbox oai_agents adapter ([#375](https://github.com/scaleapi/scale-agentex-python/issues/375)) ([e1b31d9](https://github.com/scaleapi/scale-agentex-python/commit/e1b31d91abadec572989b805592b788500d61994))
+
+
+### Performance Improvements
+
+* **tracing:** span queue linger + per-loop httpx keepalive ([#362](https://github.com/scaleapi/scale-agentex-python/issues/362)) ([feec842](https://github.com/scaleapi/scale-agentex-python/commit/feec8426f79e9f02533451d44997717655fd33f2))
+
+
+### Chores
+
+* **deps:** drop unused runtime deps and exclude tests from wheel ([#367](https://github.com/scaleapi/scale-agentex-python/issues/367)) ([f4303d1](https://github.com/scaleapi/scale-agentex-python/commit/f4303d1e7211783d19beca6554e44eb73bb29c42))
+
+
+### Refactors
+
+* **types:** promote protocol types to agentex.protocol.* ([#371](https://github.com/scaleapi/scale-agentex-python/issues/371)) ([6f1c14f](https://github.com/scaleapi/scale-agentex-python/commit/6f1c14fd61077da52038361642a9fbc4a0a56c8b))
+
 ## 0.11.4 (2026-05-26)
 
 Full Changelog: [v0.11.3...v0.11.4](https://github.com/scaleapi/scale-agentex-python/compare/v0.11.3...v0.11.4)

examples/tutorials/10_async/10_temporal/060_open_ai_agents_sdk_hello_world/tests/test_agent.py

@@ -1,3 +1,4 @@
+# ci: touch to re-run tutorial integration tests for the openai-agents>=0.14.3 bump
 """
 Sample tests for AgentEx ACP agent.
 

examples/tutorials/run_agent_test.sh

@@ -259,16 +259,23 @@ run_test() {
     cd "$tutorial_path" || return 1
 
 
-    # Run the tests with retry mechanism
-    local -a pytest_cmd=("uv" "run" "pytest")
+    # Run the tests with retry mechanism.
+    #
+    # pytest is brought in explicitly via --with: the tutorials only list it
+    # under an optional `dev` extra (which `uv run` does not install), and it
+    # used to be pulled in transitively by agentex-sdk's runtime deps. Once
+    # agentex-sdk 0.11.5 dropped pytest as a runtime dep, `uv run pytest` could
+    # no longer find it ("Failed to spawn: pytest"). Requesting it directly is
+    # robust across all tutorials regardless of how each declares test deps.
+    local -a pytest_cmd=("uv" "run" "--with" "pytest" "--with" "pytest-asyncio" "pytest")
     if [ "$BUILD_CLI" = true ]; then
         local wheel_file
         wheel_file=$(ls /home/runner/work/*/*/dist/agentex_sdk-*.whl 2>/dev/null | head -n1)
         if [[ -z "$wheel_file" ]]; then
             wheel_file=$(ls "${SCRIPT_DIR}/../../dist/agentex_sdk-*.whl" 2>/dev/null | head -n1)
         fi
         if [[ -n "$wheel_file" ]]; then
-            pytest_cmd=("uv" "run" "--with" "$wheel_file" "pytest")
+            pytest_cmd=("uv" "run" "--with" "$wheel_file" "--with" "pytest" "--with" "pytest-asyncio" "pytest")
         fi
     fi
 

pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "agentex-sdk"
-version = "0.11.4"
+version = "0.11.5"
 description = "The official Python library for the agentex API"
 dynamic = ["readme"]
 license = "Apache-2.0"
@@ -34,7 +34,7 @@ dependencies = [
     "jinja2>=3.1.3,<4",
     "mcp>=1.4.1",
     "scale-gp>=0.1.0a59",
-    "openai-agents==0.14.1",
+    "openai-agents>=0.14.3,<0.15",
     "pydantic-ai-slim>=1.0,<2",
     "json_log_formatter>=1.1.1",
     "scale-gp-beta>=0.2.0",

requirements-dev.lock

@@ -237,7 +237,7 @@ openai==2.30.0
     # via agentex-sdk
     # via litellm
     # via openai-agents
-openai-agents==0.14.1
+openai-agents==0.14.8
     # via agentex-sdk
 opentelemetry-api==1.40.0
     # via agentex-sdk

requirements.lock

@@ -215,7 +215,7 @@ openai==2.30.0
     # via agentex-sdk
     # via litellm
     # via openai-agents
-openai-agents==0.14.1
+openai-agents==0.14.8
     # via agentex-sdk
 opentelemetry-api==1.40.0
     # via agentex-sdk

src/agentex/_version.py

@@ -1,4 +1,4 @@
 # File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details.
 
 __title__ = "agentex"
-__version__ = "0.11.4"  # x-release-please-version
+__version__ = "0.11.5"  # x-release-please-version

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

@@ -7,7 +7,7 @@
 from temporalio.client import Client, WorkflowExecutionStatus
 from temporalio.common import RetryPolicy as TemporalRetryPolicy, WorkflowIDReusePolicy
 from temporalio.service import RPCError, RPCStatusCode
-from temporalio.converter import PayloadCodec
+from temporalio.converter import PayloadCodec, DataConverter
 
 from agentex.lib.utils.logging import make_logger
 from agentex.lib.utils.model_utils import BaseModel
@@ -78,11 +78,16 @@
 
 class TemporalClient:
     def __init__(
-        self, temporal_client: Client | None = None, plugins: list[Any] = [], payload_codec: PayloadCodec | None = None
+        self,
+        temporal_client: Client | None = None,
+        plugins: list[Any] = [],
+        payload_codec: PayloadCodec | None = None,
+        data_converter: DataConverter | None = None,
     ):
         self._client: Client | None = temporal_client
         self._plugins = plugins
         self._payload_codec = payload_codec
+        self._data_converter = data_converter
 
     @property
     def client(self) -> Client:
@@ -92,7 +97,13 @@ def client(self) -> Client:
         return self._client
 
     @classmethod
-    async def create(cls, temporal_address: str, plugins: list[Any] = [], payload_codec: PayloadCodec | None = None):
+    async def create(
+        cls,
+        temporal_address: str,
+        plugins: list[Any] = [],
+        payload_codec: PayloadCodec | None = None,
+        data_converter: DataConverter | None = None,
+    ):
         if temporal_address in [
             "false",
             "False",
@@ -105,8 +116,13 @@ async def create(cls, temporal_address: str, plugins: list[Any] = [], payload_co
         ]:
             _client = None
         else:
-            _client = await get_temporal_client(temporal_address, plugins=plugins, payload_codec=payload_codec)
-        return cls(_client, plugins, payload_codec)
+            _client = await get_temporal_client(
+                temporal_address,
+                plugins=plugins,
+                payload_codec=payload_codec,
+                data_converter=data_converter,
+            )
+        return cls(_client, plugins, payload_codec, data_converter)
 
     async def setup(self, temporal_address: str):
         self._client = await self._get_temporal_client(temporal_address=temporal_address)
@@ -124,7 +140,12 @@ async def _get_temporal_client(self, temporal_address: str) -> Client | None:
         ]:
             return None
         else:
-            return await get_temporal_client(temporal_address, plugins=self._plugins, payload_codec=self._payload_codec)
+            return await get_temporal_client(
+                temporal_address,
+                plugins=self._plugins,
+                payload_codec=self._payload_codec,
+                data_converter=self._data_converter,
+            )
 
     async def start_workflow(
         self,

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

@@ -6,7 +6,7 @@
 from temporalio.client import Client, Plugin as ClientPlugin
 from temporalio.worker import Interceptor
 from temporalio.runtime import Runtime, TelemetryConfig, OpenTelemetryConfig
-from temporalio.converter import PayloadCodec
+from temporalio.converter import PayloadCodec, DataConverter
 from temporalio.contrib.pydantic import pydantic_data_converter
 
 # class DateTimeJSONEncoder(AdvancedJSONEncoder):
@@ -86,6 +86,7 @@ async def get_temporal_client(
     metrics_url: str | None = None,
     plugins: list[Any] = [],
     payload_codec: PayloadCodec | None = None,
+    data_converter: DataConverter | None = None,
 ) -> Client:
     """
     Create a Temporal client with plugin integration.
@@ -94,7 +95,14 @@ async def get_temporal_client(
         temporal_address: Temporal server address
         metrics_url: Optional metrics endpoint URL
         plugins: List of Temporal plugins to include
-        payload_codec: Optional payload codec for encoding/decoding payloads (e.g. encryption, compression)
+        payload_codec: Optional payload codec for encoding/decoding payloads
+            (e.g. encryption, compression). Cannot be combined with the
+            OpenAIAgentsPlugin via this kwarg — see ``data_converter``.
+        data_converter: Optional pre-built ``DataConverter``. Use this when
+            composing the OpenAIAgentsPlugin with a payload codec: build a
+            ``DataConverter(payload_converter_class=OpenAIPayloadConverter,
+            payload_codec=...)`` and pass it here. Mutually exclusive with
+            ``payload_codec``.
 
     Returns:
         Configured Temporal client
@@ -103,29 +111,40 @@ async def get_temporal_client(
     if plugins:
         validate_client_plugins(plugins)
 
-    # Check if OpenAI plugin is present - it needs to configure its own data converter
+    if payload_codec is not None and data_converter is not None:
+        raise ValueError(
+            "Pass payload_codec inside `data_converter` "
+            "(DataConverter(..., payload_codec=...)) instead of as a separate "
+            "kwarg. Specifying both is ambiguous."
+        )
+
     # 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 []))
 
-    if has_openai_plugin and payload_codec is not None:
+    if has_openai_plugin and payload_codec is not None and data_converter is None:
         raise ValueError(
-            "payload_codec is not supported alongside OpenAIAgentsPlugin: the plugin "
-            "installs its own data converter and the codec would be silently ignored, "
-            "leaving payloads unencoded. Remove one or the other."
+            "payload_codec passed as a kwarg alongside OpenAIAgentsPlugin would "
+            "be silently dropped by the plugin's data-converter transformer. "
+            "Build a DataConverter explicitly with "
+            "`payload_converter_class=OpenAIPayloadConverter` (or a subclass) "
+            "and `payload_codec=...`, then pass it via the `data_converter` "
+            "kwarg instead."
         )
 
-    connect_kwargs = {
+    connect_kwargs: dict[str, Any] = {
         "target_host": temporal_address,
         "plugins": plugins,
     }
 
-    if not has_openai_plugin:
-        data_converter = pydantic_data_converter
-        if payload_codec:
-            data_converter = dataclasses.replace(data_converter, payload_codec=payload_codec)
+    if data_converter is not None:
         connect_kwargs["data_converter"] = data_converter
+    elif not has_openai_plugin:
+        dc = pydantic_data_converter
+        if payload_codec:
+            dc = dataclasses.replace(dc, payload_codec=payload_codec)
+        connect_kwargs["data_converter"] = dc
 
     if not metrics_url:
         client = await Client.connect(**connect_kwargs)