diff --git a/lib/sidekiq.rb b/lib/sidekiq.rb index cc8745a3..f68f8ab0 100644 --- a/lib/sidekiq.rb +++ b/lib/sidekiq.rb @@ -154,7 +154,7 @@ module Sidekiq def self.default_worker_options=(hash) # stringify - @default_worker_options = default_worker_options.merge(Hash[hash.map {|k, v| [k.to_s, v]}]) + @default_worker_options = default_worker_options.merge(Hash[hash.map { |k, v| [k.to_s, v] }]) end def self.default_worker_options diff --git a/lib/sidekiq/api.rb b/lib/sidekiq/api.rb index 9f0d051f..a0d0d436 100644 --- a/lib/sidekiq/api.rb +++ b/lib/sidekiq/api.rb @@ -86,8 +86,8 @@ module Sidekiq pipe2_res = Sidekiq.redis { |conn| conn.pipelined do - processes.each {|key| conn.hget(key, "busy") } - queues.each {|queue| conn.llen("queue:#{queue}") } + processes.each { |key| conn.hget(key, "busy") } + queues.each { |queue| conn.llen("queue:#{queue}") } end } @@ -790,7 +790,7 @@ module Sidekiq # or Sidekiq Pro. def leader @leader ||= begin - x = Sidekiq.redis {|c| c.get("dear-leader") } + x = Sidekiq.redis { |c| c.get("dear-leader") } # need a non-falsy value so we can memoize x ||= "" x diff --git a/lib/sidekiq/manager.rb b/lib/sidekiq/manager.rb index c96e3a7f..27e3d6e6 100644 --- a/lib/sidekiq/manager.rb +++ b/lib/sidekiq/manager.rb @@ -112,7 +112,7 @@ module Sidekiq end if cleanup.size > 0 - jobs = cleanup.map {|p| p.job }.compact + jobs = cleanup.map { |p| p.job }.compact logger.warn { "Terminating #{cleanup.size} busy worker threads" } logger.warn { "Work still in progress #{jobs.inspect}" } diff --git a/lib/sidekiq/web.rb b/lib/sidekiq/web.rb index 2f1873d2..b4c2bdb9 100644 --- a/lib/sidekiq/web.rb +++ b/lib/sidekiq/web.rb @@ -65,11 +65,11 @@ module Sidekiq end def enable(*opts) - opts.each {|key| set(key, true) } + opts.each { |key| set(key, true) } end def disable(*opts) - opts.each {|key| set(key, false) } + opts.each { |key| set(key, false) } end # Helper for the Sinatra syntax: Sidekiq::Web.set(:session_secret, Rails.application.secrets...) @@ -114,11 +114,11 @@ module Sidekiq end def enable(*opts) - opts.each {|key| set(key, true) } + opts.each { |key| set(key, true) } end def disable(*opts) - opts.each {|key| set(key, false) } + opts.each { |key| set(key, false) } end def set(attribute, value) @@ -187,7 +187,7 @@ module Sidekiq end end - middlewares.each {|middleware, block| use(*middleware, &block) } + middlewares.each { |middleware, block| use(*middleware, &block) } run WebApplication.new(klass) end diff --git a/lib/sidekiq/web/action.rb b/lib/sidekiq/web/action.rb index 6b975057..31f6acd2 100644 --- a/lib/sidekiq/web/action.rb +++ b/lib/sidekiq/web/action.rb @@ -23,10 +23,10 @@ module Sidekiq end def params - indifferent_hash = Hash.new {|hash, key| hash[key.to_s] if Symbol === key } + indifferent_hash = Hash.new { |hash, key| hash[key.to_s] if Symbol === key } indifferent_hash.merge! request.params - route_params.each {|k, v| indifferent_hash[k.to_s] = v } + route_params.each { |k, v| indifferent_hash[k.to_s] = v } indifferent_hash end @@ -81,7 +81,7 @@ module Sidekiq private def _erb(file, locals) - locals&.each {|k, v| define_singleton_method(k) { v } unless singleton_methods.include? k} + locals&.each { |k, v| define_singleton_method(k) { v } unless singleton_methods.include? k } if file.is_a?(String) ERB.new(file).result(binding) diff --git a/lib/sidekiq/web/application.rb b/lib/sidekiq/web/application.rb index a85e5069..d6986a44 100644 --- a/lib/sidekiq/web/application.rb +++ b/lib/sidekiq/web/application.rb @@ -342,7 +342,7 @@ module Sidekiq def self.run_hooks(hooks, app, action) hooks.select { |p, _| !p || p =~ action.env[WebRouter::PATH_INFO] } - .each {|_, b| action.instance_exec(action.env, app, &b) } + .each { |_, b| action.instance_exec(action.env, app, &b) } end def self.befores diff --git a/lib/sidekiq/worker.rb b/lib/sidekiq/worker.rb index f844c3b0..48964043 100644 --- a/lib/sidekiq/worker.rb +++ b/lib/sidekiq/worker.rb @@ -24,7 +24,7 @@ module Sidekiq attr_accessor :jid def self.included(base) - raise ArgumentError, "You cannot include Sidekiq::Worker in an ActiveJob: #{base.name}" if base.ancestors.any? {|c| c.name == "ActiveJob::Base" } + raise ArgumentError, "You cannot include Sidekiq::Worker in an ActiveJob: #{base.name}" if base.ancestors.any? { |c| c.name == "ActiveJob::Base" } base.extend(ClassMethods) base.sidekiq_class_attribute :sidekiq_options_hash @@ -124,7 +124,7 @@ module Sidekiq # options for a specific job. def sidekiq_options(opts = {}) # stringify - self.sidekiq_options_hash = get_sidekiq_options.merge(Hash[opts.map {|k, v| [k.to_s, v]}]) + self.sidekiq_options_hash = get_sidekiq_options.merge(Hash[opts.map { |k, v| [k.to_s, v] }]) end def sidekiq_retry_in(&block)