fix(llma): missing await in OpenAI's streaming implementation (#342)

* fix(llma): missing async for OpenAI async

* chore(llma): bump version

* chore(llma): bump version

Author: Radu-Raicea

CHANGELOG.md

@@ -1,3 +1,7 @@
+# 6.7.8 - 2025-10-16
+
+- fix(llma): missing async for OpenAI's streaming implementation
+
 # 6.7.7 - 2025-10-14
 
 - fix: remove deprecated attribute $exception_personURL from exception events

posthog/ai/openai/openai_async.py

@@ -128,7 +128,7 @@ async def _create_streaming(
         start_time = time.time()
         usage_stats: TokenUsage = TokenUsage()
         final_content = []
-        response = self._original.create(**kwargs)
+        response = await self._original.create(**kwargs)
 
         async def async_generator():
             nonlocal usage_stats
@@ -345,7 +345,7 @@ async def _create_streaming(
         if "stream_options" not in kwargs:
             kwargs["stream_options"] = {}
         kwargs["stream_options"]["include_usage"] = True
-        response = self._original.create(**kwargs)
+        response = await self._original.create(**kwargs)
 
         async def async_generator():
             nonlocal usage_stats
@@ -499,7 +499,7 @@ async def create(
             posthog_trace_id = str(uuid.uuid4())
 
         start_time = time.time()
-        response = self._original.create(**kwargs)
+        response = await self._original.create(**kwargs)
         end_time = time.time()
 
         # Extract usage statistics if available