Skip to content

Commit e8de395

Browse files
Wang-Daojiyuan.wang
andauthored
fix lack mem_cube_id bug in pref async (#494)
Co-authored-by: yuan.wang <[email protected]>
1 parent fa05739 commit e8de395

File tree

2 files changed

+8
-2
lines changed

2 files changed

+8
-2
lines changed

src/memos/mem_os/core.py

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -796,7 +796,11 @@ def process_preference_memory():
796796
pref_memories = self.mem_cubes[mem_cube_id].pref_mem.get_memory(
797797
messages_list,
798798
type="chat",
799-
info={"user_id": target_user_id, "session_id": self.session_id},
799+
info={
800+
"user_id": target_user_id,
801+
"session_id": self.session_id,
802+
"mem_cube_id": mem_cube_id,
803+
},
800804
)
801805
pref_ids = self.mem_cubes[mem_cube_id].pref_mem.add(pref_memories)
802806
logger.info(

src/memos/mem_scheduler/general_scheduler.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -521,7 +521,9 @@ def process_message(message: ScheduleMessageItem):
521521

522522
# Use pref_mem.get_memory to process the memories
523523
pref_memories = pref_mem.get_memory(
524-
messages_list, type="chat", info={"user_id": user_id, "session_id": session_id}
524+
messages_list,
525+
type="chat",
526+
info={"user_id": user_id, "session_id": session_id, "mem_cube_id": mem_cube_id},
525527
)
526528
# Add pref_mem to vector db
527529
pref_ids = pref_mem.add(pref_memories)

0 commit comments

Comments
 (0)