apalis-postgres 1.0.0-rc.9

Background task processing for rust using apalis and postgres
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

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

use crate::error::Error;

/// Serialized result payload including the current attempt and status
pub type Payload = TaskResult<serde_json::Value>;

/// Ack multiple tasks, given a worker
pub async fn handle_results<E>(
    executor: &mut E,
    results: &[&Payload],
    worker_id: &str,
) -> Result<u64, Error>
where
    for<'e> &'e mut E: Executor<'e, Database = sqlx::Postgres>,
{
    let payload_json = serde_json::to_value(results).map_err(Error::JsonError)?;

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

    Ok(result.rows_affected())
}