From 5fdb68bd2730e71a9c8c8273db37a1fd7096ad61 Mon Sep 17 00:00:00 2001 From: _00_ <131402327+rgaricano@users.noreply.github.com> Date: Tue, 19 Aug 2025 20:13:55 +0200 Subject: [PATCH] Fix Code Format Warmings --- backend/open_webui/main.py | 24 +++++++++++++----------- 1 file changed, 13 insertions(+), 11 deletions(-) diff --git a/backend/open_webui/main.py b/backend/open_webui/main.py index 1781dd4204..847bbaf460 100644 --- a/backend/open_webui/main.py +++ b/backend/open_webui/main.py @@ -578,17 +578,19 @@ async def lifespan(app: FastAPI): yield -# 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 + # 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}")