pub async fn run_worker( container: Container, queue: String, shutdown: ShutdownHandle, ) -> Result<(), Error>
Run the queue worker loop: pop a job, look up its runner, run it, retry on failure.