Skip to main content

Documentation Index

Fetch the complete documentation index at: https://docs.prefect.io/llms.txt

Use this file to discover all available pages before exploring further.

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