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}")