Skip to main content

apalis_sqlite/queries/
vacuum.rs

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