`archivebox.services.process_service`

Module Contents

Classes

ProcessService

Functions

parse_event_datetime

API

archivebox.services.process_service.parse_event_datetime(value: str | None)[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 on_ProcessStartedEvent__save_to_db(event: abx_dl.events.ProcessStartedEvent) → None[source]

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