BaseCheckpoint

Package: flyte

Base type for task checkpoint helpers. Subclasses load prior checkpoint data from prev_checkpoint into a local workspace and upload new state to checkpoint_path.

Properties

Methods

load()

def load()

Load checkpoint data from the remote source (async).

load_sync()

def load_sync()

Load checkpoint data from the remote source (sync task code).

prev_exists()

def prev_exists()

Whether the runtime provided a previous-checkpoint prefix (retry / resume).

save()

def save(
    data: pathlib.Path | str | bytes,
)

Save checkpoint data to the remote destination (async).

save_sync()

def save_sync(
    data: pathlib.Path | str | bytes,
)

Save checkpoint data to the remote destination (sync task code).