archivebox.services.snapshot_service

Module Contents

Classes

SnapshotService

Functions

project_discovered_snapshots	Persist parser output before the parent Snapshot can enter a final state.
finalize_completed_snapshot
_crawl_limit_stop_reason

API

archivebox.services.snapshot_service.project_discovered_snapshots(snapshot_id: str) → list

Persist parser output before the parent Snapshot can enter a final state.

archivebox.services.snapshot_service.finalize_completed_snapshot(snapshot_id: str, *, owned_retry_at, was_sealed: bool, consumed_retry_plugins: list[str] | None = None, output_dir=None, crawl_limit_stop_reason: str | None = None) → None

archivebox.services.snapshot_service._crawl_limit_stop_reason(crawl) → str

class archivebox.services.snapshot_service.SnapshotService(bus, *, crawl_id: str)

Bases: abx_dl.services.base.BaseService

Initialization

LISTENS_TO

None

EMITS

[]

async on_SnapshotEvent(event: abx_dl.events.SnapshotEvent) → None

async renew_lease(snapshot_id: str, lease_until) → bool | None

async on_SnapshotCompletedEvent(event: abx_dl.events.SnapshotCompletedEvent) → None