Skip to main content

requeue_claimed_by

Function requeue_claimed_by 

Source
pub async fn requeue_claimed_by(
    conn: &DatabaseConnection,
    worker_id: &str,
) -> Result<(), Error>
Expand description

Reset all jobs claimed by worker_id back to pending (D-10 shutdown re-queue — called by the worker loop before the process exits).