|
@@ -893,10 +893,8 @@ async def generate_chat_completion(
|
|
|
detail=detail if detail else "Open WebUI: Server Connection Error",
|
|
|
)
|
|
|
finally:
|
|
|
- if not streaming and session:
|
|
|
- if r:
|
|
|
- r.close()
|
|
|
- await session.close()
|
|
|
+ if not streaming:
|
|
|
+ await cleanup_response(r, session)
|
|
|
|
|
|
|
|
|
async def embeddings(request: Request, form_data: dict, user):
|
|
@@ -975,10 +973,8 @@ async def embeddings(request: Request, form_data: dict, user):
|
|
|
detail=detail if detail else "Open WebUI: Server Connection Error",
|
|
|
)
|
|
|
finally:
|
|
|
- if not streaming and session:
|
|
|
- if r:
|
|
|
- r.close()
|
|
|
- await session.close()
|
|
|
+ if not streaming:
|
|
|
+ await cleanup_response(r, session)
|
|
|
|
|
|
|
|
|
@router.api_route("/{path:path}", methods=["GET", "POST", "PUT", "DELETE"])
|
|
@@ -1074,7 +1070,5 @@ async def proxy(path: str, request: Request, user=Depends(get_verified_user)):
|
|
|
detail=detail if detail else "Open WebUI: Server Connection Error",
|
|
|
)
|
|
|
finally:
|
|
|
- if not streaming and session:
|
|
|
- if r:
|
|
|
- r.close()
|
|
|
- await session.close()
|
|
|
+ if not streaming:
|
|
|
+ await cleanup_response(r, session)
|