apalis_sqlite/queries/
vacuum.rs

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