lib/workless/scalers/heroku.rb in workless-1.0.2 vs lib/workless/scalers/heroku.rb in workless-1.1.0

- old
+ new

@@ -1,24 +1,24 @@ -require 'heroku' +require 'heroku-api' module Delayed module Workless module Scaler class Heroku < Base extend Delayed::Workless::Scaler::HerokuClient def self.up - client.set_workers(ENV['APP_NAME'], 1) if self.workers == 0 + client.put_workers(ENV['APP_NAME'], 1) if self.workers == 0 end def self.down - client.set_workers(ENV['APP_NAME'], 0) unless self.workers == 0 or self.jobs.count > 0 + client.put_workers(ENV['APP_NAME'], 0) unless self.workers == 0 or self.jobs.count > 0 end def self.workers - client.info(ENV['APP_NAME'])[:workers].to_i + client.get_ps(ENV['APP_NAME']).body.count { |p| p["process"] =~ /worker\.\d?/ } end end end