Skip to content

AsyncRuntimeCheckpointManager

Creates, lists, and deletes runtime checkpoints asynchronously.

Async · Sync counterpart: RuntimeCheckpointManager

class AsyncRuntimeCheckpointManager(_SdkOwnedHandle):

This type is created by the SDK; do not construct it directly.

manager = runtime.checkpoints

Create a checkpoint from this runtime and optionally wait until ready.

async def create(kind: str = 'full', name: str | None = None, *, wait: bool = True, timeout: float = 240.0, poll_interval: float = 0.5) -> CheckpointInfo
NameTypeDefaultDescription
kindstr'full'Checkpoint kind. The public API currently accepts "full".
namestr | NoneNoneOptional display name for the checkpoint.
waitboolTrueWait for the checkpoint to become ready before returning.
timeoutfloat240.0Maximum number of seconds to wait for readiness.
poll_intervalfloat0.5Seconds between readiness checks.
  • CheckpointInfo — Metadata for the created checkpoint.
>>> checkpoint = await runtime.checkpoints.create(name="worker-ready")
>>> restored = await client.runtimes.create(checkpoint_id=checkpoint.id)

List checkpoints created from this runtime.

async def list() -> list[CheckpointInfo]
  • list[CheckpointInfo]

Delete one of this runtime’s checkpoints.

async def delete(id: str) -> None
NameTypeDefaultDescription
idstrResource UUID or display name.