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
17
18
19
20
21
22
23
24
25
26
27
28

use apalis_core::{
    backend::{Backend, FetchById},
    task::{Task, task_id::TaskId},
};

use crate::{SqliteStorage, SqliteTask, error::Error, from_row::SqliteTaskRow};

impl<Args> FetchById for SqliteStorage<Args>
where
    Self: Backend<Error = Error, Task = Task<Vec<u8>>>,
    Args: 'static,
{
    fn fetch_by_id(
        &mut self,
        id: &TaskId,
    ) -> impl Future<Output = Result<Option<SqliteTask>, Self::Error>> + Send {
        let pool = self.persistence.pool.clone();
        let id = id.to_string();
        async move {
            let task = sqlx::query_file_as!(SqliteTaskRow, "queries/task/find_by_id.sql", id)
                .fetch_optional(&pool)
                .await?
                .map(|r| r.try_into())
                .transpose()?;
            Ok(task)
        }
    }
}