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

[changes] Unified management of delays

Browse Source
This commit is contained in:
lanceyq
2026-03-13 20:25:11 +08:00
parent f033607c8b
commit 4bf418a3d6
1 changed files with 1 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
api/app/controllers/memory_dashboard_controller.py
View File

@@ -198,9 +198,7 @@ async def get_workspace_end_users(
# 对有 ExtractedEntity 但无 Community 节点的存量用户自动补跑全量聚类 # 对有 ExtractedEntity 但无 Community 节点的存量用户自动补跑全量聚类
try: try:
from app.tasks import init_community_clustering_for_users from app.tasks import init_community_clustering_for_users
init_community_clustering_for_users.apply_async( init_community_clustering_for_users.delay(end_user_ids=end_user_ids)
kwargs={"end_user_ids": end_user_ids},
)
api_logger.info(f"已触发社区聚类补全任务，候选用户数: {len(end_user_ids)}") api_logger.info(f"已触发社区聚类补全任务，候选用户数: {len(end_user_ids)}")
except Exception as e: except Exception as e:
api_logger.warning(f"触发社区聚类补全任务失败（不影响主流程）: {str(e)}") api_logger.warning(f"触发社区聚类补全任务失败（不影响主流程）: {str(e)}")