fix: make low_prio queue for caching

rubyforgood · Mar 17, 2024 · 10e6605 · 10e6605
1 parent 2bcad5b
commit 10e6605
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 2 deletions.
diff --git a/app/jobs/historical_data_cache_job.rb b/app/jobs/historical_data_cache_job.rb
@@ -4,4 +4,6 @@ def perform(org_id:, type:)
 
     Rails.cache.write("#{organization.short_name}-historical-#{type}-data", HistoricalTrendService.new(organization.id, type).series)
   end
+
+  def queue_name = "low_priority"
 end
diff --git a/config/initializers/delayed_job.rb b/config/initializers/delayed_job.rb
@@ -3,7 +3,13 @@
 Delayed::Worker.max_attempts = 3
 Delayed::Worker.max_run_time = 20.minutes
 Delayed::Worker.read_ahead = 10
-Delayed::Worker.default_queue_name = 'default'
 Delayed::Worker.delay_jobs = !Rails.env.test?
 Delayed::Worker.raise_signal_exceptions = :term
 Delayed::Worker.logger = ActiveSupport::Logger.new(STDOUT)
+
+# https://github.com/rubyforgood/human-essentials/issues/4065
+Delayed::Worker.default_queue_name = 'default'
+Delayed::Worker.queue_attributes = {
+  # bigger number is lower priority ?!?!?!?!?!
+  "low_priority" => { priority: 10 } 
+}
diff --git a/spec/jobs/historical_data_cache_job_spec.rb b/spec/jobs/historical_data_cache_job_spec.rb
@@ -10,7 +10,7 @@
   it "queues the job" do
     expect { job }.to have_enqueued_job(described_class)
       .with(org_id: organization.id, type: type)
-      .on_queue("default")
+      .on_queue("low_priority")
   end
 
   it "caches the historical data" do
-Original file line number
+Diff line change
@@ Expand Up / @@ -4,4 +4,6 @@ def perform(org_id:, type:) @@
         Rails.cache.write("#{organization.short_name}-historical-#{type}-data", HistoricalTrendService.new(organization.id, type).series)
       end
+      def queue_name = "low_priority"
     end