​
prefect.server.events.messaging

​
Functions

​
publish 

publish(events: Iterable[ReceivedEvent]) -> None
Send the given events as a batch via the default publisher

​
create_event_publisher 

create_event_publisher() -> EventPublisher

​
create_actions_publisher 

create_actions_publisher() -> Publisher

​
Classes

​
EventPublisher

Methods:

​
publish_data 

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

​
publish_data 

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

​
publish_event 

publish_event(self, event: ReceivedEvent) -> None
Publishes the given events Args:
  • event: the event to publish