ordering
__init__
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.
Methods:
Was this page helpful?
Documentation Index
Fetch the complete documentation index at: /llms.txt
Use this file to discover all available pages before exploring further.
prefect.server.events.orderingget_triggers_causal_ordering get_triggers_causal_ordering() -> CausalOrdering
CausalOrderingModule EventArrivedEarly MaxDepthExceeded event_handler CausalOrdering 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
Was this page helpful?