Skip to main content

run_worker

Function run_worker 

Source
pub async fn run_worker(
    container: Container,
    queue: String,
    shutdown: ShutdownHandle,
) -> Result<(), Error>
Expand description

Run the queue worker loop: pop a job, look up its runner, run it, retry on failure.