Skip to main content

requeue_local_jobs

Function requeue_local_jobs 

Source
pub fn requeue_local_jobs(
    adapter: &dyn DatabaseOperations,
    config: &DbBackendConfig,
    schema: &AppSchema,
    retry_failed: bool,
    limit: u32,
) -> Result<usize, DatabaseError>
Expand description

Moves bounded failed or expired-lease jobs back to the queue. The status guard prevents an operator command from overwriting a concurrent worker.