fleche.storage.file

Attributes

logger

Classes

FileStorage

File-based storage backend using pickle.

Functions

file_write_lock(→ Generator[None, None, None])	Context manager for acquiring a write lock on a file.
file_read_lock(→ Generator[None, None, None])	Context manager for acquiring a read lock on a file.

Module Contents

fleche.storage.file.logger

fleche.storage.file.file_write_lock(lock_path: pathlib.Path) → Generator[None, None, None]

Context manager for acquiring a write lock on a file.

Creates a lock file with hostname, PID, and timestamp.

fleche.storage.file.file_read_lock(lock_path: pathlib.Path, timeout: float, wait_start: float, key: str) → Generator[None, None, None]

Context manager for acquiring a read lock on a file.

Waits for a lock file to be removed with exponential backoff.

class fleche.storage.file.FileStorage

Bases: fleche.storage.base.StorageBackend

File-based storage backend using pickle.

Stores objects on the filesystem.

root: pathlib.Path

lock_timeout: float = 1.0

lock_wait_start: float = 0.001

__post_init__() → None

_path(key: str) → pathlib.Path

list() → Iterable[fleche.digest.Digest]

_evict(key: fleche.digest.Digest) → None

put(value: Any, key: fleche.digest.Digest) → fleche.digest.Digest

get(key: fleche.digest.Digest) → Any

abstractmethod _to_file(value: Any, path: pathlib.Path) → None

abstractmethod _from_file(path: pathlib.Path) → Any

_contains(key: fleche.digest.Digest) → bool