Method append

openviking/ingest/replay.py:74–80

(self, ov_session_id: str, messages: List[Dict[str, Any]])

            )

    async def append(self, ov_session_id: str, messages: List[Dict[str, Any]]) -> int:
        total = 0
        for start in range(0, len(messages), _BATCH):
            chunk = messages[start : start + _BATCH]
            result = await self._client.batch_add_messages(ov_session_id, chunk)
            total += int(result.get("added", len(chunk)) or 0)
        return total

    async def commit(self, ov_session_id: str, keep_recent_count: int = 0) -> Dict[str, Any]:
        return await self._client.commit_session(ov_session_id, keep_recent_count=keep_recent_count)