release: 0.1.0-alpha.32

.release-please-manifest.json

@@ -1,3 +1,3 @@
 {
-  ".": "0.1.0-alpha.31"
+  ".": "0.1.0-alpha.32"
 }

.stats.yml

@@ -1,3 +1,3 @@
 configured_endpoints: 56
-openapi_spec_hash: ef178c3ce0c31f0785212f1138ee8eee
+openapi_spec_hash: 80b1836ebec22fc0dc25d5d8efe62a50
 config_hash: 9e0ed146f9f6e6d1884a4c0589d6f1c2

CHANGELOG.md

@@ -1,5 +1,24 @@
 # Changelog
 
+## 0.1.0-alpha.32 (2025-11-05)
+
+Full Changelog: [v0.1.0-alpha.31...v0.1.0-alpha.32](https://github.com/cleanlab/codex-python/compare/v0.1.0-alpha.31...v0.1.0-alpha.32)
+
+### Features
+
+* **api:** api update ([e8c8537](https://github.com/cleanlab/codex-python/commit/e8c853706394437e0738d53594a7d635df224117))
+
+
+### Bug Fixes
+
+* **client:** close streams without requiring full consumption ([b5a889c](https://github.com/cleanlab/codex-python/commit/b5a889c4bdd788df03f310e30d6a3ee304193f53))
+
+
+### Chores
+
+* **internal/tests:** avoid race condition with implicit client cleanup ([8f06048](https://github.com/cleanlab/codex-python/commit/8f06048416bf39cdad0290b23fd8d930be869223))
+* **internal:** grammar fix (it's -> its) ([9d4a431](https://github.com/cleanlab/codex-python/commit/9d4a4318fac51055f63af10ba451b26bc6c1f179))
+
 ## 0.1.0-alpha.31 (2025-10-28)
 
 Full Changelog: [v0.1.0-alpha.30...v0.1.0-alpha.31](https://github.com/cleanlab/codex-python/compare/v0.1.0-alpha.30...v0.1.0-alpha.31)

pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "codex-sdk"
-version = "0.1.0-alpha.31"
+version = "0.1.0-alpha.32"
 description = "Internal SDK used within cleanlab-codex package. Refer to https://pypi.org/project/cleanlab-codex/ instead."
 dynamic = ["readme"]
 license = "MIT"

src/codex/_streaming.py

@@ -57,9 +57,8 @@ def __stream__(self) -> Iterator[_T]:
         for sse in iterator:
             yield process_data(data=sse.json(), cast_to=cast_to, response=response)
 
-        # Ensure the entire stream is consumed
-        for _sse in iterator:
-            ...
+        # As we might not fully consume the response stream, we need to close it explicitly
+        response.close()
 
     def __enter__(self) -> Self:
         return self
@@ -121,9 +120,8 @@ async def __stream__(self) -> AsyncIterator[_T]:
         async for sse in iterator:
             yield process_data(data=sse.json(), cast_to=cast_to, response=response)
 
-        # Ensure the entire stream is consumed
-        async for _sse in iterator:
-            ...
+        # As we might not fully consume the response stream, we need to close it explicitly
+        await response.aclose()
 
     async def __aenter__(self) -> Self:
         return self

src/codex/_utils/_utils.py

@@ -133,7 +133,7 @@ def is_given(obj: _T | NotGiven | Omit) -> TypeGuard[_T]:
 # Type safe methods for narrowing types with TypeVars.
 # The default narrowing for isinstance(obj, dict) is dict[unknown, unknown],
 # however this cause Pyright to rightfully report errors. As we know we don't
-# care about the contained types we can safely use `object` in it's place.
+# care about the contained types we can safely use `object` in its place.
 #
 # There are two separate functions defined, `is_*` and `is_*_t` for different use cases.
 # `is_*` is for when you're dealing with an unknown input

src/codex/_version.py

@@ -1,4 +1,4 @@
 # File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details.
 
 __title__ = "codex"
-__version__ = "0.1.0-alpha.31"  # x-release-please-version
+__version__ = "0.1.0-alpha.32"  # x-release-please-version

src/codex/resources/projects/evals.py

@@ -54,7 +54,7 @@ def create(
         name: str,
         context_identifier: Optional[str] | Omit = omit,
         enabled: bool | Omit = omit,
-        guardrailed_fallback_message: Optional[str] | Omit = omit,
+        guardrailed_fallback: Optional[eval_create_params.GuardrailedFallback] | Omit = omit,
         is_default: bool | Omit = omit,
         priority: Optional[int] | Omit = omit,
         query_identifier: Optional[str] | Omit = omit,
@@ -87,8 +87,7 @@ def create(
 
           enabled: Allows the evaluation to be disabled without removing it
 
-          guardrailed_fallback_message: Fallback message to use if this eval fails and causes the response to be
-              guardrailed
+          guardrailed_fallback: message, priority, type
 
           is_default: Whether the eval is a default, built-in eval or a custom eval
 
@@ -128,7 +127,7 @@ def create(
                     "name": name,
                     "context_identifier": context_identifier,
                     "enabled": enabled,
-                    "guardrailed_fallback_message": guardrailed_fallback_message,
+                    "guardrailed_fallback": guardrailed_fallback,
                     "is_default": is_default,
                     "priority": priority,
                     "query_identifier": query_identifier,
@@ -157,7 +156,8 @@ def update(
         name: str,
         context_identifier: Optional[str] | Omit = omit,
         enabled: bool | Omit = omit,
-        guardrailed_fallback_message: Optional[str] | Omit = omit,
+        guardrailed_fallback: Optional[eval_update_params.CustomEvalCreateOrUpdateSchemaGuardrailedFallback]
+        | Omit = omit,
         is_default: bool | Omit = omit,
         priority: Optional[int] | Omit = omit,
         query_identifier: Optional[str] | Omit = omit,
@@ -190,8 +190,7 @@ def update(
 
           enabled: Allows the evaluation to be disabled without removing it
 
-          guardrailed_fallback_message: Fallback message to use if this eval fails and causes the response to be
-              guardrailed
+          guardrailed_fallback: message, priority, type
 
           is_default: Whether the eval is a default, built-in eval or a custom eval
 
@@ -230,7 +229,7 @@ def update(
         project_id: str,
         body_eval_key: str,
         enabled: bool | Omit = omit,
-        guardrailed_fallback_message: Optional[str] | Omit = omit,
+        guardrailed_fallback: Optional[eval_update_params.DefaultEvalUpdateSchemaGuardrailedFallback] | Omit = omit,
         priority: Optional[int] | Omit = omit,
         should_escalate: bool | Omit = omit,
         should_guardrail: bool | Omit = omit,
@@ -252,8 +251,7 @@ def update(
 
           enabled: Allows the evaluation to be disabled without removing it
 
-          guardrailed_fallback_message: Fallback message to use if this eval fails and causes the response to be
-              guardrailed
+          guardrailed_fallback: message, priority, type
 
           priority: Priority order for evals (lower number = higher priority) to determine primary
               eval issue to surface
@@ -288,7 +286,9 @@ def update(
         name: str | Omit = omit,
         context_identifier: Optional[str] | Omit = omit,
         enabled: bool | Omit = omit,
-        guardrailed_fallback_message: Optional[str] | Omit = omit,
+        guardrailed_fallback: Optional[eval_update_params.CustomEvalCreateOrUpdateSchemaGuardrailedFallback]
+        | Optional[eval_update_params.DefaultEvalUpdateSchemaGuardrailedFallback]
+        | Omit = omit,
         is_default: bool | Omit = omit,
         priority: Optional[int] | Omit = omit,
         query_identifier: Optional[str] | Omit = omit,
@@ -317,7 +317,7 @@ def update(
                     "name": name,
                     "context_identifier": context_identifier,
                     "enabled": enabled,
-                    "guardrailed_fallback_message": guardrailed_fallback_message,
+                    "guardrailed_fallback": guardrailed_fallback,
                     "is_default": is_default,
                     "priority": priority,
                     "query_identifier": query_identifier,
@@ -448,7 +448,7 @@ async def create(
         name: str,
         context_identifier: Optional[str] | Omit = omit,
         enabled: bool | Omit = omit,
-        guardrailed_fallback_message: Optional[str] | Omit = omit,
+        guardrailed_fallback: Optional[eval_create_params.GuardrailedFallback] | Omit = omit,
         is_default: bool | Omit = omit,
         priority: Optional[int] | Omit = omit,
         query_identifier: Optional[str] | Omit = omit,
@@ -481,8 +481,7 @@ async def create(
 
           enabled: Allows the evaluation to be disabled without removing it
 
-          guardrailed_fallback_message: Fallback message to use if this eval fails and causes the response to be
-              guardrailed
+          guardrailed_fallback: message, priority, type
 
           is_default: Whether the eval is a default, built-in eval or a custom eval
 
@@ -522,7 +521,7 @@ async def create(
                     "name": name,
                     "context_identifier": context_identifier,
                     "enabled": enabled,
-                    "guardrailed_fallback_message": guardrailed_fallback_message,
+                    "guardrailed_fallback": guardrailed_fallback,
                     "is_default": is_default,
                     "priority": priority,
                     "query_identifier": query_identifier,
@@ -551,7 +550,8 @@ async def update(
         name: str,
         context_identifier: Optional[str] | Omit = omit,
         enabled: bool | Omit = omit,
-        guardrailed_fallback_message: Optional[str] | Omit = omit,
+        guardrailed_fallback: Optional[eval_update_params.CustomEvalCreateOrUpdateSchemaGuardrailedFallback]
+        | Omit = omit,
         is_default: bool | Omit = omit,
         priority: Optional[int] | Omit = omit,
         query_identifier: Optional[str] | Omit = omit,
@@ -584,8 +584,7 @@ async def update(
 
           enabled: Allows the evaluation to be disabled without removing it
 
-          guardrailed_fallback_message: Fallback message to use if this eval fails and causes the response to be
-              guardrailed
+          guardrailed_fallback: message, priority, type
 
           is_default: Whether the eval is a default, built-in eval or a custom eval
 
@@ -624,7 +623,7 @@ async def update(
         project_id: str,
         body_eval_key: str,
         enabled: bool | Omit = omit,
-        guardrailed_fallback_message: Optional[str] | Omit = omit,
+        guardrailed_fallback: Optional[eval_update_params.DefaultEvalUpdateSchemaGuardrailedFallback] | Omit = omit,
         priority: Optional[int] | Omit = omit,
         should_escalate: bool | Omit = omit,
         should_guardrail: bool | Omit = omit,
@@ -646,8 +645,7 @@ async def update(
 
           enabled: Allows the evaluation to be disabled without removing it
 
-          guardrailed_fallback_message: Fallback message to use if this eval fails and causes the response to be
-              guardrailed
+          guardrailed_fallback: message, priority, type
 
           priority: Priority order for evals (lower number = higher priority) to determine primary
               eval issue to surface
@@ -682,7 +680,9 @@ async def update(
         name: str | Omit = omit,
         context_identifier: Optional[str] | Omit = omit,
         enabled: bool | Omit = omit,
-        guardrailed_fallback_message: Optional[str] | Omit = omit,
+        guardrailed_fallback: Optional[eval_update_params.CustomEvalCreateOrUpdateSchemaGuardrailedFallback]
+        | Optional[eval_update_params.DefaultEvalUpdateSchemaGuardrailedFallback]
+        | Omit = omit,
         is_default: bool | Omit = omit,
         priority: Optional[int] | Omit = omit,
         query_identifier: Optional[str] | Omit = omit,
@@ -711,7 +711,7 @@ async def update(
                     "name": name,
                     "context_identifier": context_identifier,
                     "enabled": enabled,
-                    "guardrailed_fallback_message": guardrailed_fallback_message,
+                    "guardrailed_fallback": guardrailed_fallback,
                     "is_default": is_default,
                     "priority": priority,
                     "query_identifier": query_identifier,