`prefect.server.events.storage.database`

Functions

`build_distinct_queries`

build_distinct_queries(db: PrefectDBInterface, events_filter: EventFilter) -> list[sa.Column['ORMEvent']]

`query_events`

query_events(session: AsyncSession, filter: EventFilter, page_size: int = INTERACTIVE_PAGE_SIZE) -> tuple[list[ReceivedEvent], int, Optional[str]]

`query_next_page`

query_next_page(session: AsyncSession, page_token: str) -> tuple[list[ReceivedEvent], int, Optional[str]]

`count_events`

count_events(session: AsyncSession, filter: EventFilter, countable: Countable, time_unit: TimeUnit, time_interval: float) -> list[EventCount]

`raw_count_events`

raw_count_events(db: PrefectDBInterface, session: AsyncSession, events_filter: EventFilter) -> int

Count events from the database with the given filter. Only returns the count and does not return any addition metadata. For additional metadata, use count_events. Args:

session: a database session
events_filter: filter criteria for events

Returns:

The count of events in the database that match the filter criteria.

`read_events`

read_events(db: PrefectDBInterface, session: AsyncSession, events_filter: EventFilter, limit: Optional[int] = None, offset: Optional[int] = None) -> Sequence['ORMEvent']

Read events from the Postgres database. Args:

session: a Postgres events session.
filter: filter criteria for events.
limit: limit for the query.
offset: offset for the query.

Returns:

A list of events ORM objects.

`write_events`

write_events(session: AsyncSession, events: list[ReceivedEvent]) -> None

Write events to the database. Args:

session: a database session
events: the events to insert

`get_max_query_parameters`

get_max_query_parameters() -> int

`get_number_of_event_fields`

get_number_of_event_fields() -> int

`get_number_of_resource_fields`

get_number_of_resource_fields() -> int

​prefect.server.events.storage.database

​Functions

​build_distinct_queries

​query_events

​query_next_page

​count_events

​raw_count_events

​read_events

​write_events

​get_max_query_parameters

​get_number_of_event_fields

​get_number_of_resource_fields