`prefect.server.models.logs`

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

Functions

`split_logs_into_batches`

split_logs_into_batches(logs: Sequence[schemas.actions.LogCreate]) -> Generator[Tuple[LogCreate, ...], None, None]

`create_logs`

create_logs(db: PrefectDBInterface, session: AsyncSession, logs: Sequence[LogCreate]) -> None

Creates new logs Args:

session: a database session
logs: a list of log schemas

Returns:

None

`read_logs`

read_logs(db: PrefectDBInterface, session: AsyncSession, log_filter: Optional[schemas.filters.LogFilter], offset: Optional[int] = None, limit: Optional[int] = None, sort: schemas.sorting.LogSort = schemas.sorting.LogSort.TIMESTAMP_ASC) -> Sequence[orm_models.Log]

Read logs. Args:

session: a database session
db: the database interface
log_filter: only select logs that match these filters
offset: Query offset
limit: Query limit
sort: Query sort

Returns:

List[orm_models.Log]: the matching logs

`delete_logs`

delete_logs(db: PrefectDBInterface, session: AsyncSession, log_filter: schemas.filters.LogFilter) -> int

flows saved_searches

⌘I

​prefect.server.models.logs

​Functions

​split_logs_into_batches

​create_logs

​read_logs

​delete_logs

`prefect.server.models.logs`

Functions

`split_logs_into_batches`

`create_logs`

`read_logs`

`delete_logs`