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