UniqAI/open-webui
1
0
Fork 0
mirror of https://github.com/open-webui/open-webui synced 2024-11-26 22:09:51 +00:00
Code Issues Actions 13 Packages Projects Releases Wiki Activity

fix: citations for the streaming have to be send before the [END]

Browse Source
This commit is contained in:
smonux 2024-10-13 18:06:25 +02:00
parent 9f4b6295b0
commit 3683334b2a
1 changed files with 10 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
backend/open_webui/main.py
View File

@ -459,7 +459,6 @@ async def handle_streaming_response(request: Request, response: Response,
content_type = response.headers["Content-Type"]
is_openai = "text/event-stream" in content_type
is_ollama = "application/x-ndjson" in content_type
def wrap_item(item):
return f"data: {item}\n\n" if is_openai else f"{item}\n"
@ -467,12 +466,16 @@ async def handle_streaming_response(request: Request, response: Response,
for item in data_items:
yield wrap_item(json.dumps(item))
citations = []
body = json.loads(request._body)
generator = original_generator
try:
while True:
peek = await anext(generator)
peek_json = extract_json(peek)
if peek == b'data: [DONE]\n' and len(citations) > 0 :
yield wrap_item(json.dumps({ "citations" : citations}))
if peek_json is None or not 'tool_calls' in peek_json['choices'][0]['delta']:
yield peek
continue
@ -520,14 +523,14 @@ async def handle_streaming_response(request: Request, response: Response,
del body["metadata"]["files"]
if tools[tool_function_name]["citation"]:
citation = {
log.debug("smonux CITATION")
citations.append( {
"source": {
"name": f"TOOL:{tools[tool_function_name]['toolkit_id']}/{tool_function_name}"
},
"document": [tool_output],
"metadata": [{"source": tool_function_name}],
}
yield wrap_item(json.dumps(citation))
})
# Append the tool output to the messages
body["messages"].append({
"role": "tool",
@ -543,11 +546,13 @@ async def handle_streaming_response(request: Request, response: Response,
# body_iterator here does not have __anext_() so it has to be done this way
generator = response.body_iterator.__aiter__()
except StopAsyncIteration as sie:
except StopAsyncIteration:
pass
except Exception as e:
log.exception(f"Error: {e}")
return StreamingResponse(
stream_wrapper(response.body_iterator, data_items),
headers=dict(response.headers),