Module: Sklaventreiber::WorkerPlugin::InstanceMethods

Defined in:
lib/sklaventreiber/workerplugin.rb

Instance Method Summary collapse

Instance Method Details

#after_destroy ⇒ Object 



24
25
26
27
28
29
30
31
32
33
34
35
 
# File 'lib/sklaventreiber/workerplugin.rb', line 24

def after_destroy
  super
  if Sklaventreiber::Config::SKLAVENTREIBER_LOG
    puts "Sklaventreiber: Job #{self.id} destroyed."
  end
  Sklaventreiber::HerokuConnection.init()
  # if there are no more jobs to work on
  if ( Navvy::Job.filter( :failed_at => nil, :completed_at => nil ).count == 0 )
    # then fire worker
    Sklaventreiber::HerokuConnection.fire_worker()
  end
end

#after_update ⇒ Object 



37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
 
# File 'lib/sklaventreiber/workerplugin.rb', line 37

def after_update
  super

  if Sklaventreiber::Config::SKLAVENTREIBER_LOG
    puts "Sklaventreiber: Job #{self.id} updated."
  end
  Sklaventreiber::HerokuConnection.init()

  # check if failed
  if ( self.failed? == true )
    # check if there are uncompleted jobs left
    if ( Job.filter( :failed_at => nil, :completed_at => nil ).count == 0 )
      # then fire worker
      Sklaventreiber::HerokuConnection.fire_worker()
    end
  end
end

#before_create ⇒ Object 



11
12
13
14
15
16
17
18
19
20
21
22
 
# File 'lib/sklaventreiber/workerplugin.rb', line 11

def before_create
        if Sklaventreiber::Config::SKLAVENTREIBER_LOG
    puts "Sklaventreiber: Job created."
  end
  Sklaventreiber::HerokuConnection.init()
  # if there is no worker hired
  if ( Sklaventreiber::HerokuConnection.is_fired?() )
    # then hire one
    Sklaventreiber::HerokuConnection.hire_worker()
  end
  super
end