github-starred/open-webui
2
0
Fork 0
mirror of https://github.com/open-webui/open-webui.git synced 2026-03-08 23:05:04 -05:00
Code Issues 308 Packages Projects Releases 100 Wiki Activity

fix: prevent pipeline filter from corrupting payload on HTTP error (#22445)

Browse Source 
In both inlet and outlet filter processing, response.json() was called
BEFORE response.raise_for_status(). When a filter endpoint returns an
HTTP error, the user's chat payload gets silently overwritten with the
error response body. If the error is not caught, the corrupted payload
propagates through subsequent filters and into the chat completion.

Swapped the order so raise_for_status() runs first — payload is only
updated on success.

Co-authored-by: gambletan <ethanchang32@gmail.com>
This commit is contained in:
Alvin Tang
2026-03-09 05:44:35 +08:00
committed by GitHub
parent bbbe2b66b4
commit f78b238b40
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
backend/open_webui/routers/pipelines.py
View File

@@ -92,8 +92,8 @@ async def process_pipeline_inlet_filter(request, payload, user, models):
json=request_data,
ssl=AIOHTTP_CLIENT_SESSION_SSL,
) as response:
payload = await response.json()
response.raise_for_status()
payload = await response.json()
except aiohttp.ClientResponseError as e:
res = (
await response.json()
@@ -145,8 +145,8 @@ async def process_pipeline_outlet_filter(request, payload, user, models):
json=request_data,
ssl=AIOHTTP_CLIENT_SESSION_SSL,
) as response:
payload = await response.json()
response.raise_for_status()
payload = await response.json()
except aiohttp.ClientResponseError as e:
try:
res = (