worker/jobs: Use dedicated repository queue

This allows the other jobs to make progress without getting held up by the git repository mutex.

Author: Turbo87

src/bin/background-worker.rs

@@ -105,6 +105,7 @@ fn main() -> anyhow::Result<()> {
 
     let runner = Runner::new(runtime.handle(), connection_pool, environment.clone())
         .configure_default_queue(|queue| queue.num_workers(5))
+        .configure_queue("repository", |queue| queue.num_workers(1))
         .register_crates_io_job_types()
         .start();
 

src/worker/jobs/git.rs

@@ -29,6 +29,7 @@ impl SyncToGitIndex {
 impl BackgroundJob for SyncToGitIndex {
     const JOB_NAME: &'static str = "sync_to_git_index";
     const PRIORITY: i16 = 100;
+    const QUEUE: &'static str = "repository";
 
     type Context = Arc<Environment>;
 
@@ -165,6 +166,7 @@ pub struct SquashIndex;
 #[async_trait]
 impl BackgroundJob for SquashIndex {
     const JOB_NAME: &'static str = "squash_index";
+    const QUEUE: &'static str = "repository";
 
     type Context = Arc<Environment>;
 
@@ -223,6 +225,7 @@ impl NormalizeIndex {
 #[async_trait]
 impl BackgroundJob for NormalizeIndex {
     const JOB_NAME: &'static str = "normalize_index";
+    const QUEUE: &'static str = "repository";
 
     type Context = Arc<Environment>;