lib/workless/scalers/local.rb in workless-1.2.3 vs lib/workless/scalers/local.rb in workless-2.2.0

- old
+ new

@@ -1,36 +1,37 @@ +# frozen_string_literal: true + require 'rush' module Delayed module Workless module Scaler class Local < Base - def self.executable_prefix if defined? Delayed::Compatibility.executable_prefix Delayed::Compatibility.executable_prefix else 'script' end end def self.up - if self.workers == 0 - Rush::Box.new[Rails.root].bash("#{executable_prefix}/delayed_job start -i workless", :background => true) + if workers == 0 + Rush::Box.new[Rails.root].bash("#{executable_prefix}/delayed_job start -i workless", background: true) sleep 1 end true end def self.down - if self.workers > 0 and jobs.count == 0 - Rush::Box.new[Rails.root].bash("#{executable_prefix}/delayed_job stop -i workless", :background => true) + if workers > 0 && jobs.count == 0 + Rush::Box.new[Rails.root].bash("#{executable_prefix}/delayed_job stop -i workless", background: true) end true end def self.workers - Rush::Box.new.processes.filter(:cmdline => /delayed_job start -i workless|delayed_job.workless/).size + Rush::Box.new.processes.filter(cmdline: /delayed_job start -i workless|delayed_job.workless/).size end end end end end