`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

composite_trigger_child_firing db

⌘I

API Reference

init

`prefect.server.events.ordering`

Functions

`get_triggers_causal_ordering`

Classes

`CausalOrderingModule`

`EventArrivedEarly`

`MaxDepthExceeded`

`event_handler`

`CausalOrdering`

`event_has_been_seen`

`forget_follower`

`get_followers`

`get_lost_followers`

`preceding_event_confirmed`

`record_event_as_seen`

`record_follower`

​prefect.server.events.ordering

​Functions

​get_triggers_causal_ordering

​Classes

​CausalOrderingModule

​EventArrivedEarly

​MaxDepthExceeded

​event_handler

​CausalOrdering

​event_has_been_seen

​forget_follower

​get_followers

​get_lost_followers

​preceding_event_confirmed

​record_event_as_seen

​record_follower

`prefect.server.events.ordering`

Functions

`get_triggers_causal_ordering`

Classes

`CausalOrderingModule`

`EventArrivedEarly`

`MaxDepthExceeded`

`event_handler`

`CausalOrdering`

`event_has_been_seen`

`forget_follower`

`get_followers`

`get_lost_followers`

`preceding_event_confirmed`

`record_event_as_seen`

`record_follower`