Documentation Index Fetch the complete documentation index at: https://docs.prefect.io/llms.txt
Use this file to discover all available pages before exploring further.
prefect.server.events.storage.databaseFunctions 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 sessionevents_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 sessionevents: 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
