Skip to content

vllm_omni.host_weight_runtime.filesystem.store

Crash-safe node-local filesystem implementation of HostWeightStore.

logger module-attribute

logger = logging.getLogger(__name__)

FilesystemHostWeightStore

A cooperative local store with stable locks and immutable publication.

artifacts_dir instance-attribute

artifacts_dir = self.root / 'artifacts'

capacity_policy instance-attribute

capacity_policy = capacity

deny_dir instance-attribute

deny_dir = self.root / 'deny'

domain_policy instance-attribute

domain_policy = domain

integrity_policy instance-attribute

integrity_policy = integrity

locks_dir instance-attribute

locks_dir = self.root / 'locks'

quarantine_dir instance-attribute

quarantine_dir = self.root / 'quarantine'

root instance-attribute

root = domain.root.expanduser().resolve()

tmp_dir instance-attribute

tmp_dir = self.root / 'tmp'

cleanup

cleanup(
    identity: WeightArtifactIdentity,
) -> HostWeightFailure | None

Explicitly remove an inactive artifact without waiting for leases.

get_or_build

get_or_build(
    request: BuildRequest,
    producer: WeightProducer,
    *,
    validation: ValidationLevel,
    deadline: float,
) -> StoreResult

inspect_artifact

inspect_artifact(
    identity: WeightArtifactIdentity,
    *,
    validation: ValidationLevel,
) -> ArtifactInspection

inspect_domain

inspect_domain() -> DomainInspection

lookup

lookup(
    identity: WeightArtifactIdentity,
    *,
    validation: ValidationLevel,
    deadline: float | None = None,
) -> StoreResult

detect_filesystem_type

detect_filesystem_type(path: Path) -> str

Return the kernel filesystem type for the most specific mount.

detect_storage_class

detect_storage_class(path: Path) -> StorageClass

Classify a verified node-local mount without spawning platform tools.