From 4bf418a3d6714c16e7537e588adcb9106c01f634 Mon Sep 17 00:00:00 2001 From: lanceyq <1982376970@qq.com> Date: Fri, 13 Mar 2026 20:25:11 +0800 Subject: [PATCH] [changes] Unified management of delays --- api/app/controllers/memory_dashboard_controller.py | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/api/app/controllers/memory_dashboard_controller.py b/api/app/controllers/memory_dashboard_controller.py index 92d0ff36..bad706d4 100644 --- a/api/app/controllers/memory_dashboard_controller.py +++ b/api/app/controllers/memory_dashboard_controller.py @@ -198,9 +198,7 @@ async def get_workspace_end_users( # 对有 ExtractedEntity 但无 Community 节点的存量用户自动补跑全量聚类 try: from app.tasks import init_community_clustering_for_users - init_community_clustering_for_users.apply_async( - kwargs={"end_user_ids": end_user_ids}, - ) + init_community_clustering_for_users.delay(end_user_ids=end_user_ids) api_logger.info(f"已触发社区聚类补全任务，候选用户数: {len(end_user_ids)}") except Exception as e: api_logger.warning(f"触发社区聚类补全任务失败（不影响主流程）: {str(e)}")