Add unsafe capsule and reports_creator queue with concncurrency of 1

ministryofjustice · Dec 20, 2024 · bcfddd8 · bcfddd8
1 parent 0c5d8f4
commit bcfddd8
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 0 deletions.
diff --git a/app/workers/reports_creator_worker.rb b/app/workers/reports_creator_worker.rb
@@ -1,6 +1,7 @@
 class ReportsCreatorWorker
   include Sidekiq::Worker
   include Sidekiq::Status::Worker
+  sidekiq_options queue: :reports_creator
 
   def perform(legal_aid_application_id)
     legal_aid_application = LegalAidApplication.find(legal_aid_application_id)

diff --git a/config/initializers/sidekiq.rb b/config/initializers/sidekiq.rb
@@ -22,6 +22,12 @@
   # accepts :expiration (optional)
   Sidekiq::Status.configure_client_middleware config, expiration: 30.minutes.to_i
 
+  config.capsule("unsafe") do |cap|
+    cap.concurrency = 1
+    cap.queues = %w[reports_creator] # strict priority
+    # cap.queues = %w[queue_a,3 queue_b,1] # weighted
+  end
+
   if Rails.env.production? && Rails.configuration.x.kubernetes_deployment
     config.server_middleware do |chain|
       Rails.logger.info "[SidekiqPrometheusExporter] Chaining middleware..."

diff --git a/config/sidekiq.yml b/config/sidekiq.yml
@@ -1,5 +1,6 @@
 ---
 :queues:
+  - reports_creator
   - default
   - mailers
   - active_storage_analysis