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 ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/events/ordering/__init__.py#L90" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

get_triggers_causal_ordering() -> CausalOrdering

Classes

CausalOrderingModule ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/events/ordering/__init__.py#L42" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

EventArrivedEarly ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/events/ordering/__init__.py#L46" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

MaxDepthExceeded ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/events/ordering/__init__.py#L51" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

event_handler ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/events/ordering/__init__.py#L56" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

CausalOrdering ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/events/ordering/__init__.py#L62" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

Methods:

event_has_been_seen ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/events/ordering/__init__.py#L67" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

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

forget_follower ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/events/ordering/__init__.py#L76" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

forget_follower(self, follower: ReceivedEvent) -> None

get_followers ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/events/ordering/__init__.py#L79" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

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

get_lost_followers ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/events/ordering/__init__.py#L82" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

get_lost_followers(self) -> List[ReceivedEvent]

preceding_event_confirmed ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/events/ordering/__init__.py#L85" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

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

record_event_as_seen ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/events/ordering/__init__.py#L70" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

record_event_as_seen(self, event: ReceivedEvent) -> None

record_follower ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/events/ordering/__init__.py#L73" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

record_follower(self, event: ReceivedEvent) -> None