pub async fn retry_failed_by_queue<'e, E>( executor: E, queue: &str, ) -> Result<Vec<JobRow>, AwaError>where E: PgExecutor<'e>,
Retry all failed jobs in a given queue.