Skip to main content

prefect.events.worker

Functions

should_emit_events

should_emit_events() -> bool

emit_events_to_cloud

emit_events_to_cloud() -> bool

should_emit_events_to_running_server

should_emit_events_to_running_server() -> bool

should_emit_events_to_ephemeral_server

should_emit_events_to_ephemeral_server() -> bool

Classes

ProcessPoolForwardingEventsClient

An events client that forwards events to a parent process queue. Methods:

client_name

client_name(self) -> str

emit

emit(self, event: Event) -> None
Emit a single event

EventsWorker

Methods:
attach_related_resources_from_context(self, event: Event) -> None

instance

instance(cls: Type[Self], client_type: Optional[Type[EventsClient]] = None) -> Self

set_client_override

set_client_override(cls, client_type: Optional[Type[EventsClient]], **client_kwargs: Any) -> None