Fix fireworks stream completion

This commit is contained in:
Ashwin Bharambe 2024-11-19 13:36:14 -08:00
parent 05d1ead02f
commit 38ba3b9f0c

View file

@ -214,10 +214,10 @@ class FireworksInferenceAdapter(
async def _to_async_generator(): async def _to_async_generator():
if "messages" in params: if "messages" in params:
stream = await self._get_client().chat.completions.acreate(**params) stream = self._get_client().chat.completions.acreate(**params)
else: else:
stream = self._get_client().completion.create(**params) stream = self._get_client().completion.acreate(**params)
for chunk in stream: async for chunk in stream:
yield chunk yield chunk
stream = _to_async_generator() stream = _to_async_generator()