From d02b6a21fc02fb073782e25356968cfee3c45c36 Mon Sep 17 00:00:00 2001 From: Timothy Jaeryang Baek Date: Fri, 14 Aug 2026 00:55:21 -0600 Subject: [PATCH] refac --- backend/open_webui/utils/middleware.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/backend/open_webui/utils/middleware.py b/backend/open_webui/utils/middleware.py index 7c1785de6d..1e322838da 100644 --- a/backend/open_webui/utils/middleware.py +++ b/backend/open_webui/utils/middleware.py @@ -4637,16 +4637,16 @@ async def streaming_chat_response_handler(response, ctx): ) # Check for Responses API events (type field starts with "response.") elif data.get('type', '').startswith('response.'): - response_event_type = data.get('type', '') - response_event_is_delta = response_event_type.endswith('.delta') + response_data_type = data.get('type', '') + response_data_is_delta = response_data_type.endswith('.delta') output, response_metadata = handle_responses_streaming_event(data, output) - if not response_event_is_delta: + if not response_data_is_delta: await flush_pending_delta_data() # Emit citation sources from finalized output items # (mirrors Chat Completions annotation handling at delta level) - if response_event_type == 'response.output_item.done': + if response_data_type == 'response.output_item.done': item = data.get('item', {}) if item.get('type') == 'message': for part in item.get('content', []):