Class: Sidekiq::Superworker::Processor
- Inherits:
-
Object
- Object
- Sidekiq::Superworker::Processor
- 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 = find_subjob_by_jid(item['jid']) SubjobProcessor.error(subjob, worker, item, exception) if subjob end |