apalis-sqlite 1.0.0-rc.11

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

use sqlx::Executor;

/// Lock multiple tasks, given a worker
pub async fn lock_tasks<'a, E>(
    executor: E,
    task_ids: &[String],
    worker_id: &str,
) -> Result<u64, sqlx::Error>
where
    E: Executor<'a, Database = sqlx::Sqlite>,
{
    let ids_json = serde_json::to_string(task_ids).map_err(|e| sqlx::Error::Decode(Box::new(e)))?;

    let res = sqlx::query_file!("queries/task/lock.sql", ids_json, worker_id)
        .execute(executor)
        .await?;

    Ok(res.rows_affected())
}