`archivebox.crawls.locks`

Module Contents

Classes

_LifecycleLockState

Functions

`crawl_lifecycle_lock_path`
`_lifecycle_lock`
`crawl_lifecycle_lock`
`binary_lifecycle_lock`

Data

`_registry_lock`
`_registry_pid`
`_registry`

API

class archivebox.crawls.locks._LifecycleLockState[source]: Initialization

archivebox.crawls.locks._registry_lock[source]: ‘Lock(…)’

archivebox.crawls.locks._registry_pid[source]: ‘getpid(…)’

archivebox.crawls.locks._registry: dict[str, archivebox.crawls.locks._LifecycleLockState][source]: None

archivebox.crawls.locks.crawl_lifecycle_lock_path(crawl_id: str) → pathlib.Path[source]

archivebox.crawls.locks._lifecycle_lock(key: str, lock_path: pathlib.Path) → collections.abc.Iterator[None][source]

archivebox.crawls.locks.crawl_lifecycle_lock(crawl_id: str) → collections.abc.Iterator[None][source]

archivebox.crawls.locks.binary_lifecycle_lock(binary_id: str) → collections.abc.Iterator[None][source]