class Sidekiq::Superworker::Processor

Public Instance Methods

complete(item, new_thread=true) click to toggle source
# 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) click to toggle source
# 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

Protected Instance Methods

complete_item(item) click to toggle source
# File lib/sidekiq/superworker/processor.rb, line 20
def complete_item(item)
  raise "Job has nil jid: #{item}" if item['jid'].nil?

  Superworker.debug "JID ##{item['jid']}: Passing job from Sidekiq to Superworker"
  subjob = Subjob.find_by_jid(item['jid'])
  SubjobProcessor.complete(subjob) if subjob
end