fix(openai): implement aclose on async stream responses

langfuse · Feb 12, 2025 · beb1d98 · beb1d98
1 parent cd8c118
commit beb1d98
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/langfuse/openai.py b/langfuse/openai.py
@@ -977,3 +977,10 @@ async def close(self) -> None:
         Automatically called if the response body is read to completion.
         """
         await self.response.close()
+
+    async def aclose(self) -> None:
+        """Close the response and release the connection.
+
+        Automatically called if the response body is read to completion.
+        """
+        await self.response.aclose()