Skip to main content

apalis_postgres/queries/
lock_task.rs

1use sqlx::{Error, Executor};
2
3/// Lock multiple tasks, given a worker
4pub async fn lock_tasks<E>(conn: &mut E, task_ids: &[String], worker_id: &str) -> Result<u64, Error>
5where
6    for<'e> &'e mut E: Executor<'e, Database = sqlx::Postgres>,
7{
8    let res = sqlx::query_file!("queries/task/lock_by_id.sql", task_ids, worker_id)
9        .execute(&mut *conn)
10        .await?;
11
12    Ok(res.rows_affected())
13}