class RedisVLMessageStore(ChatMessageStoreProtocol): ... async def add_messages(self, messages: Sequence[ChatMessage]): messages = [self._to_redis_message(message) for message in messages] self._message_history.add_messages( messages, session_tag=self._session_tag )