Module: Resque::Kubernetes::Worker::InstanceMethods

Defined in:
lib/resque/kubernetes/worker.rb

Overview

Replace methods on the worker instance

Instance Method Summary collapse

Instance Method Details

#prepare ⇒ Object 



28
29
30
31
 
# File 'lib/resque/kubernetes/worker.rb', line 28

def prepare
  self.term_on_empty = ENV["TERM_ON_EMPTY"] if ENV["TERM_ON_EMPTY"]
  super
end

#shutdown? ⇒ Boolean

Returns:

  • (Boolean) 


33
34
35
36
37
38
39
40
41
42
 
# File 'lib/resque/kubernetes/worker.rb', line 33

def shutdown?
  if term_on_empty
    if queues_empty?
      log_with_severity :info, "shutdown: queues are empty"
      shutdown
    end
  end

  super
end