mirror of
https://github.com/open-webui/open-webui.git
synced 2025-12-14 21:35:19 +00:00
Fix Code Format Warmings
This commit is contained in:
parent
8a423c0a98
commit
5fdb68bd27
1 changed files with 13 additions and 11 deletions
|
|
@ -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}")
|
||||
|
||||
|
|
|
|||
Loading…
Reference in a new issue