Skip to main content

reenqueue_abandoned

Function reenqueue_abandoned 

Source
pub async fn reenqueue_abandoned<E>(
    executor: &mut E,
    queue: &str,
    worker: &str,
    task_ids: &[String],
) -> Result<u64, Error>
where for<'e> &'e mut E: Executor<'e, Database = Postgres>,
Expand description

Rescues tasks that could not be executed after a worker shutdown