Sha256: a30a0cd5d85f0bda138cffb0e15e6dd24355c1ddfb5123e490755f02ff6ffb68
Contents?: true
Size: 707 Bytes
Versions: 27
Compression:
Stored size: 707 Bytes
Contents
require 'rush'
module Delayed
module Workless
module Scaler
class Local < Base
def self.up
if self.workers == 0
Rush::Box.new[Rails.root].bash("script/delayed_job start -i workless", :background => true)
sleep 1
end
true
end
def self.down
unless jobs.count > 0 and workers > 0
Rush::Box.new[Rails.root].bash("script/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
end
end
end
end
end
Version data entries
27 entries across 27 versions & 2 rubygems