Merge pull request #314 from tsujigiri/move-frequency-jobs-to-frequency-queue

Move Frequency jobs to frequency queue
This commit is contained in:
Philipp Bayer
2016-06-27 10:04:40 +08:00
committed by GitHub
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');