fix(express): 修复异步会话中错误的删除操作
在 `ExpressionLearner` 的 `decay` 方法中,`session.delete(expr)` 操作是同步的,但在异步会话(`AsyncSession`)上下文中应该使用 `await`。此更改修复了该问题,确保表达式能被正确地异步删除。
This commit is contained in:
@@ -262,7 +262,7 @@ class ExpressionLearner:
|
|||||||
|
|
||||||
if new_count <= 0.01:
|
if new_count <= 0.01:
|
||||||
# 如果count太小,删除这个表达方式
|
# 如果count太小,删除这个表达方式
|
||||||
session.delete(expr)
|
await session.delete(expr)
|
||||||
await session.commit()
|
await session.commit()
|
||||||
deleted_count += 1
|
deleted_count += 1
|
||||||
else:
|
else:
|
||||||
@@ -536,7 +536,7 @@ class ExpressionLearnerManager:
|
|||||||
return
|
return
|
||||||
|
|
||||||
if os.path.exists(done_flag):
|
if os.path.exists(done_flag):
|
||||||
logger.info("表达方式JSON已迁移,无需重复迁移。")
|
logger.debug("表达方式JSON已迁移,无需重复迁移。")
|
||||||
return
|
return
|
||||||
|
|
||||||
logger.info("开始迁移表达方式JSON到数据库...")
|
logger.info("开始迁移表达方式JSON到数据库...")
|
||||||
|
|||||||
Reference in New Issue
Block a user