phoenix/litellm-mirror
0
0
Fork 1
mirror of https://github.com/BerriAI/litellm.git synced 2025-04-27 11:43:54 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix azure streaming

Browse source
This commit is contained in:
Krrish Dholakia 2023-09-02 16:10:19 -07:00
parent 78cd8d6e27
commit a07251a514
3 changed files with 7 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

BIN
litellm/__pycache__/utils.cpython-311.pyc
View file

Binary file not shown.

7
litellm/utils.py
View file

@ -1801,7 +1801,10 @@ class CustomStreamWrapper:
raise ValueError(f"Unable to parse response. Original response: {chunk}") raise ValueError(f"Unable to parse response. Original response: {chunk}")
def handle_openai_chat_completion_chunk(self, chunk): def handle_openai_chat_completion_chunk(self, chunk):
return chunk["choices"][0]["delta"]["content"] try:
return chunk["choices"][0]["delta"]["content"]
except:
return ""
def handle_baseten_chunk(self, chunk): def handle_baseten_chunk(self, chunk):
try: try:
@ -1874,7 +1877,7 @@ class CustomStreamWrapper:
threading.Thread(target=self.logging_obj.success_handler, args=(completion_obj,)).start() threading.Thread(target=self.logging_obj.success_handler, args=(completion_obj,)).start()
# return this for all models # return this for all models
return {"choices": [{"delta": completion_obj}]} return {"choices": [{"delta": completion_obj}]}
except: except Exception as e:
raise StopIteration raise StopIteration
async def __anext__(self): async def __anext__(self):

2
pyproject.toml
View file

@ -1,6 +1,6 @@
[tool.poetry] [tool.poetry]
name = "litellm" name = "litellm"
version = "0.1.517" version = "0.1.518"
description = "Library to easily interface with LLM API providers" description = "Library to easily interface with LLM API providers"
authors = ["BerriAI"] authors = ["BerriAI"]
license = "MIT License" license = "MIT License"