ti.sil/open-webui
1
0
Fork 0
mirror of https://github.com/open-webui/open-webui.git synced 2025-12-12 20:35:19 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 4

UPD: ExceptionGroup catch - update main.py

Browse source 
ExceptionGroup catch - update main.py for catch and handle multiple concurrent exceptions

Add caching for concurrent exceptions.
Modified:
- redis_task_command_listener
This commit is contained in:
_00_ 2025-08-19 19:13:04 +02:00 committed by GitHub
parent 631d4441aa
commit aa5f5330d3
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 13 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
backend/open_webui/main.py
View file

@ -578,8 +578,19 @@ async def lifespan(app: FastAPI):
yield
if hasattr(app.state, "redis_task_command_listener"):
app.state.redis_task_command_listener.cancel()
# In the lifespan shutdown
if hasattr(app.state, "redis_task_command_listener"):
try:
app.state.redis_task_command_listener.cancel()
await app.state.redis_task_command_listener
except ExceptionGroup as eg:
log.error(f"Multiple errors during listener shutdown: {len(eg.exceptions)} exceptions")
for exc in eg.exceptions:
log.error(f"Shutdown error: {type(exc).__name__}: {exc}")
except asyncio.CancelledError:
pass # Expected during shutdown
except Exception as e:
log.error(f"Error during listener shutdown: {e}")
app = FastAPI(