adai/MemoryBear
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[fix] iron release

Browse Source
This commit is contained in:
lanceyq
2026-03-30 18:29:17 +08:00
parent c90b58bbcd
commit 0c677701c0
1 changed files with 5 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
api/app/tasks.py
View File

@@ -1244,6 +1244,11 @@ def write_message_task(
"task_id": self.request.id "task_id": self.request.id
} }
finally: finally:
if lock is not None:
try:
lock.release()
except Exception as e:
logger.warning(f"[CELERY WRITE] 释放锁失败: {e}")
# Gracefully shutdown the event loop to prevent # Gracefully shutdown the event loop to prevent
# 'RuntimeError: Event loop is closed' from httpx.AsyncClient.__del__ # 'RuntimeError: Event loop is closed' from httpx.AsyncClient.__del__
_shutdown_loop_gracefully(loop) _shutdown_loop_gracefully(loop)