apalis_sqlite/queries/
vacuum.rs

1use apalis_core::backend::{Backend, Vacuum};
2use ulid::Ulid;
3
4use crate::{CompactType, SqliteStorage};
5
6impl<Args, F, Decode> Vacuum for SqliteStorage<Args, Decode, F>
7where
8    SqliteStorage<Args, Decode, F>:
9        Backend<IdType = Ulid, Codec = Decode, Error = sqlx::Error, Compact = CompactType>,
10    F: Send,
11    Decode: Send,
12    Args: Send,
13{
14    async fn vacuum(&mut self) -> Result<usize, Self::Error> {
15        let res = sqlx::query_file!("queries/backend/vacuum.sql")
16            .execute(&self.pool)
17            .await?;
18        Ok(res.rows_affected() as usize)
19    }
20}