diff options
author | David Heinemeier Hansson <david@loudthinking.com> | 2014-05-20 17:37:10 +0200 |
---|---|---|
committer | David Heinemeier Hansson <david@loudthinking.com> | 2014-05-20 17:37:10 +0200 |
commit | b13a3cb29b7b8823a085977dc6de801fb65acf71 (patch) | |
tree | 32b58e0a1af6968e09de942687bc02af47e58717 /lib/active_job | |
parent | 1d519aae29228186d3e82906d5d6e8dda2e91bd3 (diff) | |
download | rails-b13a3cb29b7b8823a085977dc6de801fb65acf71.tar.gz rails-b13a3cb29b7b8823a085977dc6de801fb65acf71.tar.bz2 rails-b13a3cb29b7b8823a085977dc6de801fb65acf71.zip |
Styling
Diffstat (limited to 'lib/active_job')
-rw-r--r-- | lib/active_job/queue_adapters/sidekiq_adapter.rb | 13 |
1 files changed, 6 insertions, 7 deletions
diff --git a/lib/active_job/queue_adapters/sidekiq_adapter.rb b/lib/active_job/queue_adapters/sidekiq_adapter.rb index 0cf9e47287..43bd69790c 100644 --- a/lib/active_job/queue_adapters/sidekiq_adapter.rb +++ b/lib/active_job/queue_adapters/sidekiq_adapter.rb @@ -5,11 +5,11 @@ module ActiveJob class SidekiqAdapter class << self def queue(job, *args) - item = { 'class' => JobWrapper, - 'queue' => job.queue_name, - 'args' => [job, *args], - 'retry' => true } - Sidekiq::Client.push(item) + Sidekiq::Client.push \ + 'class' => JobWrapper, + 'queue' => job.queue_name, + 'args' => [ job, *args ], + 'retry' => true end end @@ -17,8 +17,7 @@ module ActiveJob include Sidekiq::Worker def perform(job_name, *args) - instance = job_name.constantize.new - instance.perform *Parameters.deserialize(args) + job_name.constantize.new.perform *Parameters.deserialize(args) end end end |