I noticed this when I was using concurrency with ActiveJob. For the example below, only 2 instances of ExampleJob would process and not clear the lock.
class ApplicationJob < ActiveJob::Base
include Sidekiq::Throttled::Job
end
class ExampleJob < ApplicationJob
sidekiq_throttle(
concurrency: { limit: 2 },
)
def perform
# do something
end
end
Digging deeper, this call was missed in earlier changes to support ActiveJob. Fixed that and added tests to prevent regression.
I noticed this when I was using concurrency with
ActiveJob
. For the example below, only 2 instances of ExampleJob would process and not clear the lock.Digging deeper, this call was missed in earlier changes to support ActiveJob. Fixed that and added tests to prevent regression.