vendoring openai 2.7.1

Author: csgulati09

portkey_ai/__init__.py

@@ -155,6 +155,8 @@
     AsyncChatKitThreads,
     Calls,
     AsyncCalls,
+    InputTokens,
+    AsyncInputTokens,
 )
 
 from portkey_ai.version import VERSION
@@ -329,4 +331,6 @@
     "AsyncChatKitThreads",
     "Calls",
     "AsyncCalls",
+    "InputTokens",
+    "AsyncInputTokens",
 ]

…_vendor/openai-2.2.0.dist-info/INSTALLER …_vendor/openai-2.7.1.dist-info/INSTALLERportkey_ai/_vendor/openai-2.2.0.dist-info/INSTALLER renamed to portkey_ai/_vendor/openai-2.7.1.dist-info/INSTALLER portkey_ai/_vendor/openai-2.2.0.dist-info/INSTALLER renamed to portkey_ai/_vendor/openai-2.7.1.dist-info/INSTALLER

@@ -1,6 +1,6 @@
 Metadata-Version: 2.3
 Name: openai
-Version: 2.2.0
+Version: 2.7.1
 Summary: The official Python library for the openai API
 Project-URL: Homepage, https://github.com/openai/openai-python
 Project-URL: Repository, https://github.com/openai/openai-python
@@ -25,14 +25,14 @@ Requires-Python: >=3.8
 Requires-Dist: anyio<5,>=3.5.0
 Requires-Dist: distro<2,>=1.7.0
 Requires-Dist: httpx<1,>=0.23.0
-Requires-Dist: jiter<1,>=0.4.0
+Requires-Dist: jiter<1,>=0.10.0
 Requires-Dist: pydantic<3,>=1.9.0
 Requires-Dist: sniffio
 Requires-Dist: tqdm>4
 Requires-Dist: typing-extensions<5,>=4.11
 Provides-Extra: aiohttp
 Requires-Dist: aiohttp; extra == 'aiohttp'
-Requires-Dist: httpx-aiohttp>=0.1.8; extra == 'aiohttp'
+Requires-Dist: httpx-aiohttp>=0.1.9; extra == 'aiohttp'
 Provides-Extra: datalib
 Requires-Dist: numpy>=1; extra == 'datalib'
 Requires-Dist: pandas-stubs>=1.1.0.11; extra == 'datalib'
@@ -290,7 +290,9 @@ async def main():
     client = AsyncOpenAI()
 
     async with client.realtime.connect(model="gpt-realtime") as connection:
-        await connection.session.update(session={'modalities': ['text']})
+        await connection.session.update(
+            session={"type": "realtime", "output_modalities": ["text"]}
+        )
 
         await connection.conversation.item.create(
             item={
@@ -302,10 +304,10 @@ async def main():
         await connection.response.create()
 
         async for event in connection:
-            if event.type == 'response.text.delta':
+            if event.type == "response.output_text.delta":
                 print(event.delta, flush=True, end="")
 
-            elif event.type == 'response.text.done':
+            elif event.type == "response.output_text.done":
                 print()
 
             elif event.type == "response.done":

…/_vendor/openai-2.2.0.dist-info/METADATA …/_vendor/openai-2.7.1.dist-info/METADATAportkey_ai/_vendor/openai-2.2.0.dist-info/METADATA renamed to portkey_ai/_vendor/openai-2.7.1.dist-info/METADATA portkey_ai/_vendor/openai-2.2.0.dist-info/METADATA renamed to portkey_ai/_vendor/openai-2.7.1.dist-info/METADATA

@@ -96,9 +96,8 @@ def __stream__(self) -> Iterator[_T]:
 
                 yield process_data(data=data, 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
@@ -198,9 +197,8 @@ async def __stream__(self) -> AsyncIterator[_T]:
 
                 yield process_data(data=data, 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

…ai/_vendor/openai-2.2.0.dist-info/RECORD …ai/_vendor/openai-2.7.1.dist-info/RECORDportkey_ai/_vendor/openai-2.2.0.dist-info/RECORD renamed to portkey_ai/_vendor/openai-2.7.1.dist-info/RECORD portkey_ai/_vendor/openai-2.2.0.dist-info/RECORD renamed to portkey_ai/_vendor/openai-2.7.1.dist-info/RECORD

@@ -137,7 +137,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