Merge branch 'main' into stas/agent-auth

Author: smoreinis

.release-please-manifest.json

@@ -1,3 +1,3 @@
 {
-  ".": "0.2.1"
+  ".": "0.2.2"
 }

.stats.yml

@@ -1,4 +1,4 @@
 configured_endpoints: 34
-openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/sgp%2Fagentex-sdk-782d59cf134b51ddd5058ae6e1630057093a6034b1d90663ab67836802b67cc6.yml
-openapi_spec_hash: 3356926852d5d095d572b4fdce242836
+openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/sgp%2Fagentex-sdk-ed22476258be08ff765c68dcb29c08baf3e4783c98edac50d1e8003e9487db37.yml
+openapi_spec_hash: d4010bb4bf479073328ca00be01a7b96
 config_hash: 7c1f6794a184ee175dd94f2f7c2b496b

CHANGELOG.md

@@ -1,5 +1,13 @@
 # Changelog
 
+## 0.2.2 (2025-07-28)
+
+Full Changelog: [v0.2.1...v0.2.2](https://github.com/scaleapi/agentex-python/compare/v0.2.1...v0.2.2)
+
+### Features
+
+* **api:** api update ([eb79533](https://github.com/scaleapi/agentex-python/commit/eb79533dd041b7fccccc6a75abedd0c87e9c55e5))
+
 ## 0.2.1 (2025-07-27)
 
 Full Changelog: [v0.2.0...v0.2.1](https://github.com/scaleapi/agentex-python/compare/v0.2.0...v0.2.1)

pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "agentex-sdk"
-version = "0.2.1"
+version = "0.2.2"
 description = "The official Python library for the agentex API"
 dynamic = ["readme"]
 license = "Apache-2.0"

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.2.1"  # x-release-please-version
+__version__ = "0.2.2"  # x-release-please-version

src/agentex/lib/adk/_modules/messages.py

@@ -4,7 +4,7 @@
 
 from agentex import AsyncAgentex
 from agentex.lib.adk.utils._modules.client import create_async_agentex_client
-from agentex.lib.core.adapters.streams.adapter_redis import RedisEventStreamRepository
+from agentex.lib.core.adapters.streams.adapter_redis import RedisStreamRepository
 from agentex.lib.core.services.adk.messages import MessagesService
 from agentex.lib.core.services.adk.streaming import StreamingService
 from agentex.lib.core.temporal.activities.activity_helpers import ActivityHelpers
@@ -39,7 +39,7 @@ def __init__(
     ):
         if messages_service is None:
             agentex_client = create_async_agentex_client()
-            stream_repository = RedisEventStreamRepository()
+            stream_repository = RedisStreamRepository()
             streaming_service = StreamingService(
                 agentex_client=agentex_client,
                 stream_repository=stream_repository,

src/agentex/lib/adk/_modules/streaming.py

@@ -2,7 +2,7 @@
 
 from agentex import AsyncAgentex
 from agentex.lib.adk.utils._modules.client import create_async_agentex_client
-from agentex.lib.core.adapters.streams.adapter_redis import RedisEventStreamRepository
+from agentex.lib.core.adapters.streams.adapter_redis import RedisStreamRepository
 from agentex.lib.core.services.adk.streaming import (
     StreamingService,
     StreamingTaskMessageContext,
@@ -34,7 +34,7 @@ def __init__(self, streaming_service: StreamingService | None = None):
                 a new service will be created with default parameters.
         """
         if streaming_service is None:
-            stream_repository = RedisEventStreamRepository()
+            stream_repository = RedisStreamRepository()
             agentex_client = create_async_agentex_client()
             self._streaming_service = StreamingService(
                 agentex_client=agentex_client,

src/agentex/resources/tasks.py

@@ -206,7 +206,7 @@ def stream_events(
         timeout: float | httpx.Timeout | None | NotGiven = NOT_GIVEN,
     ) -> Stream[object]:
         """
-        Stream events for a task by its unique ID.
+        Stream message updates for a task by its unique ID.
 
         Args:
           extra_headers: Send extra headers
@@ -241,7 +241,7 @@ def stream_events_by_name(
         timeout: float | httpx.Timeout | None | NotGiven = NOT_GIVEN,
     ) -> Stream[object]:
         """
-        Stream events for a task by its unique name.
+        Stream message updates for a task by its unique name.
 
         Args:
           extra_headers: Send extra headers
@@ -448,7 +448,7 @@ async def stream_events(
         timeout: float | httpx.Timeout | None | NotGiven = NOT_GIVEN,
     ) -> AsyncStream[object]:
         """
-        Stream events for a task by its unique ID.
+        Stream message updates for a task by its unique ID.
 
         Args:
           extra_headers: Send extra headers
@@ -483,7 +483,7 @@ async def stream_events_by_name(
         timeout: float | httpx.Timeout | None | NotGiven = NOT_GIVEN,
     ) -> AsyncStream[object]:
         """
-        Stream events for a task by its unique name.
+        Stream message updates for a task by its unique name.
 
         Args:
           extra_headers: Send extra headers