From a53be317656c1c2f17db96e143be4ea29bba9a31 Mon Sep 17 00:00:00 2001 From: lixinyue <2569494688@qq.com> Date: Tue, 27 Jan 2026 11:41:16 +0800 Subject: [PATCH] =?UTF-8?q?=E6=A3=80=E6=9F=A5=E9=9C=80=E8=A6=81=E6=9B=B4?= =?UTF-8?q?=E6=94=B9=E7=9A=84=E6=A0=BC=E5=BC=8F=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../forgetting_engine/forgetting_scheduler.py | 2 +- api/app/services/memory_storage_service.py | 12 ++++++++++-- 2 files changed, 11 insertions(+), 3 deletions(-) diff --git a/api/app/core/memory/storage_services/forgetting_engine/forgetting_scheduler.py b/api/app/core/memory/storage_services/forgetting_engine/forgetting_scheduler.py index 5a178fc2..072d587c 100644 --- a/api/app/core/memory/storage_services/forgetting_engine/forgetting_scheduler.py +++ b/api/app/core/memory/storage_services/forgetting_engine/forgetting_scheduler.py @@ -343,7 +343,7 @@ class ForgettingScheduler: params = {} if end_user_id: - end_user_id['end_user_id'] = end_user_id + params['end_user_id'] = end_user_id results = await self.connector.execute_query(query, **params) diff --git a/api/app/services/memory_storage_service.py b/api/app/services/memory_storage_service.py index 0ede7bd3..784288de 100644 --- a/api/app/services/memory_storage_service.py +++ b/api/app/services/memory_storage_service.py @@ -182,13 +182,21 @@ class DataConfigService: # 数据配置服务类（PostgreSQL） # 将 ORM 对象转换为字典列表 data_list = [] for config in configs: + # 安全地转换 user_id 为 int + config_id_old = None + if config.user_id: + try: + config_id_old = int(config.user_id) + except (ValueError, TypeError): + config_id_old = None + config_dict = { "config_id": config.config_id, "config_name": config.config_name, "config_desc": config.config_desc, "workspace_id": str(config.workspace_id) if config.workspace_id else None, "end_user_id": config.end_user_id, - "config_id_old": int(config.user_id), + "config_id_old": config_id_old, "apply_id": config.apply_id, "llm_id": config.llm_id, "embedding_id": config.embedding_id, @@ -268,7 +276,7 @@ class DataConfigService: # 数据配置服务类（PostgreSQL） try: config_service = MemoryConfigService(self.db) memory_config = config_service.load_memory_config( - config_id=int(cid), + config_id=str(cid), service_name="MemoryStorageService.pilot_run_stream" ) logger.info(f"Configuration loaded successfully: {memory_config.config_name}")