__init__

​

prefect.server.events.ordering

Manages the partial causal ordering of events for a particular consumer. This module maintains a buffer of events to be processed, aiming to process them in the order they occurred causally.

​

Functions

​

get_triggers_causal_ordering

get_triggers_causal_ordering() -> CausalOrdering

​

Classes

​

CausalOrderingModule

​

EventArrivedEarly

​

MaxDepthExceeded

​

event_handler

​

CausalOrdering

Methods:

​

event_has_been_seen

event_has_been_seen(self, event: Union[UUID, Event]) -> bool

​

forget_follower

forget_follower(self, follower: ReceivedEvent) -> None

​

get_followers

get_followers(self, leader: ReceivedEvent) -> List[ReceivedEvent]

​

get_lost_followers

get_lost_followers(self) -> List[ReceivedEvent]

​

preceding_event_confirmed

preceding_event_confirmed(self, handler: event_handler, event: ReceivedEvent, depth: int = 0) -> AsyncContextManager[None]

​

record_event_as_seen

record_event_as_seen(self, event: ReceivedEvent) -> None

​

record_follower

record_follower(self, event: ReceivedEvent) -> None