Skip to main content

ack_tasks

Function ack_tasks 

Source
pub async fn ack_tasks<'a, E>(
    executor: E,
    messages: &[&AckPayload],
    worker_id: &str,
) -> Result<u64, Error>
where E: Executor<'a, Database = Sqlite>,
Expand description

Ack multiple tasks, given a worker