aboutsummaryrefslogtreecommitdiffstats
path: root/lib
diff options
context:
space:
mode:
authorDavid Heinemeier Hansson <david@loudthinking.com>2014-05-20 17:37:10 +0200
committerDavid Heinemeier Hansson <david@loudthinking.com>2014-05-20 17:37:10 +0200
commitb13a3cb29b7b8823a085977dc6de801fb65acf71 (patch)
tree32b58e0a1af6968e09de942687bc02af47e58717 /lib
parent1d519aae29228186d3e82906d5d6e8dda2e91bd3 (diff)
downloadrails-b13a3cb29b7b8823a085977dc6de801fb65acf71.tar.gz
rails-b13a3cb29b7b8823a085977dc6de801fb65acf71.tar.bz2
rails-b13a3cb29b7b8823a085977dc6de801fb65acf71.zip
Styling
Diffstat (limited to 'lib')
-rw-r--r--lib/active_job/queue_adapters/sidekiq_adapter.rb13
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