Skip to main content

reenqueue_orphaned

Function reenqueue_orphaned 

Source
pub async fn reenqueue_orphaned<E>(
    conn: &mut E,
    queue: &str,
    dead_for: u64,
) -> Result<u64, Error>
where for<'e> &'e mut E: Executor<'e, Database = Postgres>,
Expand description

Reenqueue jobs orphaned by a dead worker