Class: Delayed::Workless::Scaler::Local

Inherits:
Base
  • Object
show all
Defined in:
lib/workless/scalers/local.rb

Instance Method Summary collapse

Methods inherited from Base

#jobs

Instance Method Details

#down ⇒ Object 



14
15
16
17
 
# File 'lib/workless/scalers/local.rb', line 14

def down
  Rush::Box.new.processes.filter(:cmdline => /rake jobs:work/).kill unless workers == 0 or jobs.count > 0
  true
end

#up ⇒ Object 



9
10
11
12
 
# File 'lib/workless/scalers/local.rb', line 9

def up
  Rush::Box.new[Rails.root].bash("rake jobs:work", :background => true)
  true
end

#workers ⇒ Object 



19
20
21
 
# File 'lib/workless/scalers/local.rb', line 19

def workers
  Rush::Box.new.processes.filter(:cmdline => /rake jobs:work/).size
end