EventManager | API | Crawlee for Python · Fast, reliable Python web crawlers.
Index
Methods
- async __aenter__(): EventManager
- async __aexit__(exc_type, exc_value, exc_traceback): None
Parameters
exc_type: type[BaseException] | None
exc_value: BaseException | None
exc_traceback: TracebackType | None
Returns None
- __init__(*, persist_state_interval, close_timeout): None
Parameters
optionalkeyword-onlypersist_state_interval: timedelta = timedelta(minutes=1)
optionalkeyword-onlyclose_timeout: timedelta | None = None
Returns None
- emit(*: , event: Event, event_data: EventData): None
- emit(*: , event: Literal[Event.PERSIST_STATE], event_data: EventPersistStateData): None
- emit(*: , event: Literal[Event.SYSTEM_INFO], event_data: EventSystemInfoData): None
- emit(*: , event: Literal[Event.MIGRATING], event_data: EventMigratingData): None
- emit(*: , event: Literal[Event.ABORTING], event_data: EventAbortingData): None
- emit(*: , event: Literal[Event.EXIT], event_data: EventExitData): None
- emit(*: , event: Literal[Event.CRAWLER_STATUS], event_data: EventCrawlerStatusData): None
- emit(*: , event: Event, event_data: Any): None
- off(*, event, listener): None
Parameters
keyword-onlyevent: Event
optionalkeyword-onlylistener: EventListener[Any] | None = None
Returns None
- on(*: , event: Event, listener: EventListener[Any]): None
- on(*: , event: Literal[Event.PERSIST_STATE], listener: EventListener[EventPersistStateData]): None
- on(*: , event: Literal[Event.SYSTEM_INFO], listener: EventListener[EventSystemInfoData]): None
- on(*: , event: Literal[Event.MIGRATING], listener: EventListener[EventMigratingData]): None
- on(*: , event: Literal[Event.ABORTING], listener: EventListener[EventAbortingData]): None
- on(*: , event: Literal[Event.EXIT], listener: EventListener[EventExitData]): None
- on(*: , event: Literal[Event.CRAWLER_STATUS], listener: EventListener[EventCrawlerStatusData]): None
- on(*: , event: Event, listener: EventListener[None]): None
Parameters
keyword-onlyevent: Event
keyword-onlylistener: EventListener[Any]
Returns None
- async wait_for_all_listeners_to_complete(*, timeout): None
Parameters
optionalkeyword-onlytimeout: timedelta | None = None
Returns None