apalis-sqlite 1.0.0-rc.9

Background task processing for rust using apalis and sqlite
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

use apalis_core::backend::{Backend, Vacuum};

use crate::{Error, SqliteStorage};

impl<Args> Vacuum for SqliteStorage<Args>
where
    Self: Backend<Error = Error>,
    Args: Send,
{
    async fn vacuum(&mut self) -> Result<usize, Self::Error> {
        let res = sqlx::query_file!("queries/backend/vacuum.sql")
            .execute(&self.persistence.pool)
            .await?;
        Ok(res.rows_affected() as usize)
    }
}