`archivebox.services.snapshot_service`

Module Contents

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

archivebox.services.snapshot_service.project_discovered_snapshots(snapshot_id: str) → list[source]: Persist parser output before the parent Snapshot can enter a final state.

archivebox.services.snapshot_service.finalize_completed_snapshot(snapshot_id: str, *, output_dir=None, crawl_limit_stop_reason: str | None = None) → None[source]

archivebox.services.snapshot_service._crawl_limit_stop_reason(crawl) → str[source]

class archivebox.services.snapshot_service.SnapshotService(bus, *, crawl_id: str, schedule_snapshot)[source]

Bases: abx_dl.services.base.BaseService

Initialization

async on_SnapshotEvent(event: abx_dl.events.SnapshotEvent) → None[source]

async on_SnapshotCompletedEvent(event: abx_dl.events.SnapshotCompletedEvent) → None[source]