CheckpointStore

Bases: Protocol

Persistence Protocol for owner-supplied task resume state.

Implementations write opaque JSON-serialisable dicts keyed by task_id and read them back. The framework never inspects the payload — the owner picks what to checkpoint, when, and how to interpret it on resume. read returns None if no checkpoint has been written for the given id.

Networked agents typically use HubBackedCheckpointStore (in autogen.beta.network.client.checkpoint) which delegates to the hub. Standalone agents may supply any store satisfying this Protocol or omit checkpointing entirely.

write(task_id, state)

95

async def write(self, task_id: str, state: dict[str, Any]) -> None: ...

read(task_id)

97

async def read(self, task_id: str) -> dict[str, Any] | None: ...