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
20
21
22
23
24

use apalis_core::backend::TaskResult;
use sqlx::Executor;

/// Represents the result of a `SqliteTask` execution
pub type AckPayload = TaskResult<serde_json::Value>;

/// Ack multiple tasks, given a worker
pub async fn ack_tasks<'a, E>(
    executor: E,
    messages: &[&AckPayload],
    worker_id: &str,
) -> Result<u64, sqlx::Error>
where
    E: Executor<'a, Database = sqlx::Sqlite>,
{
    let payload_json =
        serde_json::to_string(&messages).map_err(|e| sqlx::Error::Encode(Box::new(e)))?;

    let result = sqlx::query_file!("queries/task/ack.sql", payload_json, worker_id)
        .execute(executor)
        .await?;

    Ok(result.rows_affected())
}