`archivebox.services.process_service`

Module Contents

Classes

ProcessService

Functions

`parse_event_datetime`
`current_network_interface_with_machine`

API

archivebox.services.process_service.parse_event_datetime(value: str | None)[source]

archivebox.services.process_service.current_network_interface_with_machine()[source]

class archivebox.services.process_service.ProcessService(bus)[source]

Bases: abx_dl.services.base.BaseService

Initialization

LISTENS_TO: ClassVar[list[type[abxbus.BaseEvent]]][source]: None

EMITS: ClassVar[list[type[abxbus.BaseEvent]]][source]: []

async current_iface()[source]

async on_ProcessStartedEvent__save_to_db(event: abx_dl.events.ProcessStartedEvent) → None[source]

async _completed_worker_loop() → None[source]

_ensure_completed_worker() → None[source]

async on_ProcessCompletedEvent__save_to_db(event: abx_dl.events.ProcessCompletedEvent) → None[source]

async flush_completed() → None[source]

async on_CrawlCleanupEvent__flush_completed(event: abx_dl.events.CrawlCleanupEvent) → None[source]

async on_CrawlCompletedEvent__flush_completed(event: abx_dl.events.CrawlCompletedEvent) → None[source]

async _save_completed_process_to_db(event: abx_dl.events.ProcessCompletedEvent) → None[source]