reenqueue_orphaned

Function reenqueue_orphaned 

Source
pub fn reenqueue_orphaned(
    pool: SqlitePool,
    config: &Config,
) -> impl Future<Output = Result<u64, Error>> + Send
Expand description

Re-enqueue tasks that were being processed by workers that have not sent a keep-alive signal within the specified duration