`prefect.server.events.messaging`

Functions

publish(events: Iterable[ReceivedEvent]) -> None

Send the given events as a batch via the default publisher

create_event_publisher() -> EventPublisher

create_actions_publisher() -> Publisher

Methods:

publish_data(self, data: bytes, attributes: Mapping[str, str]) -> None

publish_data(self, data: bytes, attributes: Mapping[str, str]) -> None

publish_event(self, event: ReceivedEvent) -> None

Publishes the given events Args: