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