prefect.server.events.messaging

Functions

publish ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/events/messaging.py#L19" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

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

Send the given events as a batch via the default publisher

create_event_publisher ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/events/messaging.py#L78" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

create_event_publisher() -> EventPublisher

create_actions_publisher ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/events/messaging.py#L83" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

create_actions_publisher() -> Publisher

Classes

EventPublisher ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/events/messaging.py#L26" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

Methods:

publish_data ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/events/messaging.py#L41" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

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

publish_data ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/utilities/messaging/__init__.py#L68" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

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

publish_event ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/events/messaging.py#L44" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

publish_event(self, event: ReceivedEvent) -> None

Publishes the given events

Args:

• event: the event to publish