Fix API failing to cancel streams (attempt), closes #6966

This commit is contained in:
oobabooga 2025-05-10 17:55:48 -07:00
parent 47d4758509
commit 006a866079

View file

@ -118,6 +118,7 @@ async def openai_completions(request: Request, request_data: CompletionRequest):
for resp in response:
disconnected = await request.is_disconnected()
if disconnected:
stop_everything_event()
break
yield {"data": json.dumps(resp)}
@ -141,6 +142,7 @@ async def openai_chat_completions(request: Request, request_data: ChatCompletion
for resp in response:
disconnected = await request.is_disconnected()
if disconnected:
stop_everything_event()
break
yield {"data": json.dumps(resp)}