archivebox.services.process_service

Module Contents

Classes

ProcessService

Functions

parse_event_datetime

current_network_interface_with_machine

normalize_process_env

API

archivebox.services.process_service.parse_event_datetime(value: str | None)[source]
archivebox.services.process_service.current_network_interface_with_machine()[source]
archivebox.services.process_service.normalize_process_env(env: dict) → dict[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]