diff --git a/posthog/ai/openai/openai_async.py b/posthog/ai/openai/openai_async.py
index 69cce4c8..9fcce1ae 100644
--- a/posthog/ai/openai/openai_async.py
+++ b/posthog/ai/openai/openai_async.py
@@ -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