dragon.data.ddict.DAOSCheckpointPersister

class DAOSCheckpointPersister

Bases: CheckpointPersister

__init__(ddict_name: str , persist_path: str , manager_id: int , log, manager, persist_freq: int = 0, persist_count: int = 0)

Methods

__init__(ddict_name, persist_path, ...[, ...])
advance()	Used internally to advance the persisted checkpoint ID to the next available one.
checkpoints()	Return an iterator of all valid persisted checkpoint IDs in ascending order.
cleanup_metadata(persist_path, name)
dump(chkpt[, force])	Dump retiring checkpoint to disk and retire the checkpoint.
dump_metadata(orc_logger, persist_path, ...)
load(pool[, cleanup])	Load persisted checkpoint from disk and return the checkpoint.
load_metadata(orc_logger, persist_path, name)
position(chkpt_id)	Used internally to set the checkpoint ID to an available persistsed checkpoint.
prepare(orc_logger, persist_path, name, ...)

Attributes

current_chkpt

__init__(ddict_name: str , persist_path: str , manager_id: int , log, manager, persist_freq: int = 0, persist_count: int = 0)

classmethod prepare(orc_logger, persist_path, name, restore_from, read_only: bool = False)

classmethod dump_metadata(orc_logger, persist_path, name, metadata)

classmethod load_metadata(orc_logger, persist_path, name) → str

classmethod cleanup_metadata(persist_path, name)

dump(chkpt, force: bool = False)

Dump retiring checkpoint to disk and retire the checkpoint.

load(pool: MemoryPool, cleanup: bool = False)

Load persisted checkpoint from disk and return the checkpoint.

advance()

Used internally to advance the persisted checkpoint ID to the next available one.

position(chkpt_id: int )

Used internally to set the checkpoint ID to an available persistsed checkpoint.

checkpoints() → list [int ]

Return an iterator of all valid persisted checkpoint IDs in ascending order.

property current_chkpt