Agent Sessions

from ai_query.agents import (
    AgentSession,
    AgentSessionCatalog,
    AgentSessionInfo,
    AgentSessionPage,
    AgentSessionSnapshot,
)

session = agent.session
snapshot = await session.snapshot()

async def snapshot(self) -> AgentSessionSnapshot

snapshot = await agent.session.snapshot()
print(snapshot.id, snapshot.state)
for message in snapshot.messages:
    print(message.role, message.content)

async def replace_messages(self, messages: Sequence[Message]) -> None

await agent.session.replace_messages(compacted_messages)

async def clear_messages(self) -> None

async def replay_events(self, after_id: int = 0) -> AsyncIterator[Event]

async def clear_events(self) -> None

def turn(
    self,
    content: Content,
    *,
    options: TurnOptions | None = None,
) -> AgentTurn

async def abort(self, reason: str | None = None) -> bool

storage = SQLiteStorage("agents.db")
server = AgentServer(MyAgent, session_storage=storage)

page = await server.sessions.list(page=1, page_size=20)
info = await server.sessions.get("conversation-123")
await server.sessions.evict("conversation-123")
await server.sessions.delete("conversation-123")

async def list(
    self,
    *,
    page: int = 1,
    page_size: int = 20,
) -> AgentSessionPage

async def get(self, session_id: str) -> AgentSessionInfo | None

async def evict(self, session_id: str) -> bool

async def delete(self, session_id: str) -> bool