​
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

​
get_task_run_recorder_causal_ordering 

get_task_run_recorder_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