__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

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