Class: Sidekiq::LimitFetch::UnitOfWork

Inherits:
BasicFetch::UnitOfWork
  • Object
show all
Defined in:
lib/sidekiq/limit_fetch/unit_of_work.rb

Overview

Sidekiq’s object to track a job being processed. fetcher_class#retrieve_work is expected to return, so it must be a somewhat public API.

Instance Method Summary collapse

Instance Method Details

#acknowledgeObject

Acknowledge completion of job



9
10
11
# File 'lib/sidekiq/limit_fetch/unit_of_work.rb', line 9

def acknowledge
  Global::QueueSemaphore.new(config, queue_name).release
end

#requeueObject

Put the job back in Redis.



14
15
16
17
# File 'lib/sidekiq/limit_fetch/unit_of_work.rb', line 14

def requeue
  acknowledge
  super
end