prefect.server.models.saved_searches

Functions for interacting with saved search ORM objects. Intended for internal use by the Prefect REST API.

Functions

create_saved_search(db: PrefectDBInterface, session: AsyncSession, saved_search: schemas.core.SavedSearch) -> orm_models.SavedSearch
Upserts a SavedSearch. If a SavedSearch with the same name exists, all properties will be updated. Args:
  • session: a database session
  • saved_search: a SavedSearch model
Returns:
  • orm_models.SavedSearch: the newly-created or updated SavedSearch
read_saved_search(db: PrefectDBInterface, session: AsyncSession, saved_search_id: UUID) -> Union[orm_models.SavedSearch, None]
Reads a SavedSearch by id. Args:
  • session: A database session
  • saved_search_id: a SavedSearch id
Returns:
  • orm_models.SavedSearch: the SavedSearch

read_saved_search_by_name

read_saved_search_by_name(db: PrefectDBInterface, session: AsyncSession, name: str) -> Union[orm_models.SavedSearch, None]
Reads a SavedSearch by name. Args:
  • session: A database session
  • name: a SavedSearch name
Returns:
  • orm_models.SavedSearch: the SavedSearch

read_saved_searches

read_saved_searches(db: PrefectDBInterface, session: AsyncSession, offset: Optional[int] = None, limit: Optional[int] = None) -> Sequence[orm_models.SavedSearch]
Read SavedSearches. Args:
  • session: A database session
  • offset: Query offset
  • limit(int): Query limit
Returns:
  • List[orm_models.SavedSearch]: SavedSearches
delete_saved_search(db: PrefectDBInterface, session: AsyncSession, saved_search_id: UUID) -> bool
Delete a SavedSearch by id. Args:
  • session: A database session
  • saved_search_id: a SavedSearch id
Returns:
  • whether or not the SavedSearch was deleted