`archivebox.services.snapshot_service`

Module Contents

Classes

SnapshotService

API

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

Bases: abx_dl.services.base.BaseService

Initialization

LISTENS_TO[source]: None

EMITS[source]: []

async _upsert_discovered_snapshot(parent_snapshot, *, url: str, depth: int, title: str = '', tags: str = '') → str | None[source]

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

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

_crawl_limit_stop_reason(crawl) → str[source]