Class: Sidekiq::Superworker::Processor

Inherits:
Object
  • Object
show all
Defined in:
lib/sidekiq/superworker/processor.rb

Instance Method Summary collapse

Instance Method Details

#complete(item, new_thread = true) ⇒ Object 



4
5
6
7
8
 
# File 'lib/sidekiq/superworker/processor.rb', line 4

def complete(item, new_thread=true)
  Superworker.debug "JID ##{item['jid']}: Sidekiq job complete"

  complete_item(item)
end

#error(worker, item, queue, exception) ⇒ Object 



10
11
12
13
14
15
16
 
# File 'lib/sidekiq/superworker/processor.rb', line 10

def error(worker, item, queue, exception)
  raise "Job has nil jid: #{item}" if item['jid'].nil?

  Superworker.debug "JID ##{item['jid']}: Error thrown"
  subjob = Subjob.find_by_jid(item['jid'])
  SubjobProcessor.error(subjob, worker, item, exception) if subjob
end