diff --git a/openviking/session/session.py b/openviking/session/session.py index 84b8a76e..243069a1 100644 --- a/openviking/session/session.py +++ b/openviking/session/session.py @@ -337,6 +337,9 @@ async def commit_async(self) -> Dict[str, Any]: ) memories = await self._session_compressor.extract_long_term_memories( messages=messages_to_archive, + user=self.user, + session_id=self.session_id, + ctx=self.ctx, ) logger.info(f"Extracted {len(memories)} memories") result["memories_extracted"] = len(memories)