pipeline

prefect.server.events.pipeline

Classes

EventsPipeline

Methods:

events_to_messages

events_to_messages(events: list[Event]) -> list[MemoryMessage]

process_events

process_events(self, events: list[Event]) -> None

process_message

process_message(self, message: MemoryMessage) -> None

Process a single event message

process_messages

process_messages(self, messages: list[MemoryMessage]) -> None