Move Frequency jobs to frequency queue

In order to not block the parsing jobs, move the frequency jobs to a
different queue.
This commit is contained in:
Helge Rausch
2016-06-26 14:21:52 +02:00
parent b88242ad14
commit 105515efa9
3 changed files with 13 additions and 1 deletions

View File

@@ -1,6 +1,6 @@
class Frequency
include Sidekiq::Worker
sidekiq_options queue: :user_snps, retry: 5, unique: true
sidekiq_options queue: :frequency, retry: 5, unique: true
def perform(snp_id)
Snp.reset_counters(snp_id, :user_snps)

View File

@@ -0,0 +1,10 @@
class MoveFrequencyJobsToFrequencyQueue < ActiveRecord::Migration
def change
Sidekiq::Queue.new('user_snps').each do |job|
if job.klass == 'Frequency'
Frequency.perform_async(*job.args)
job.delete
end
end
end
end

View File

@@ -1971,3 +1971,5 @@ INSERT INTO schema_migrations (version) VALUES ('20151119070640');
INSERT INTO schema_migrations (version) VALUES ('20160207043305');
INSERT INTO schema_migrations (version) VALUES ('20160626121340');