Fix API issues

This commit is contained in:
oobabooga 2025-05-18 12:45:01 -07:00
parent 126b3a768f
commit 83bfd5c64b

View file

@ -114,8 +114,8 @@ async def openai_completions(request: Request, request_data: CompletionRequest):
if request_data.stream:
async def generator():
try:
async with streaming_semaphore:
try:
response = OAIcompletions.stream_completions(to_dict(request_data), is_legacy=is_legacy)
async for resp in iterate_in_threadpool(response):
disconnected = await request.is_disconnected()
@ -124,6 +124,7 @@ async def openai_completions(request: Request, request_data: CompletionRequest):
yield {"data": json.dumps(resp)}
finally:
stop_everything_event()
return
return EventSourceResponse(generator()) # SSE streaming
@ -145,8 +146,8 @@ async def openai_chat_completions(request: Request, request_data: ChatCompletion
if request_data.stream:
async def generator():
try:
async with streaming_semaphore:
try:
response = OAIcompletions.stream_chat_completions(to_dict(request_data), is_legacy=is_legacy)
async for resp in iterate_in_threadpool(response):
disconnected = await request.is_disconnected()
@ -155,6 +156,7 @@ async def openai_chat_completions(request: Request, request_data: ChatCompletion
yield {"data": json.dumps(resp)}
finally:
stop_everything_event()
return
return EventSourceResponse(generator()) # SSE streaming