sidekiq-unique-jobs: Duplicated jobs on the queue

Describe the bug

Multiple jobs with same parameters are added to the process queue.

Expected behavior No duplication of job with same argument are added to the queue.

Current behavior

We have multiple jobs with these options: sidekiq_options lock: :until_executed, unique_args: ->(args) { [args.first] }, on_conflict: :reject

ProcessObjectType1, ProcessObjectType2…

For some reason, one class: ProcessJourney has duplicated jobs in the queue (our queue should contain 200k items and it has 800k+, as jobs are duplicated).

What’s also strange is that they don’t seem to get processed at all, yet their number if going up and down (mostly growing). We have lots of dead jobs too, so some are getting rejected.

Worker class

# frozen_string_literal: true

module JourneyManagement
  module Job
    class ProcessJourney
      include Sidekiq::Worker
      # sidekiq_options queue: 'default'

      sidekiq_options lock: :until_executed, unique_args: ->(args) { [args.first] }, on_conflict: :reject

      # ------------------------------------------------------------------------------
      def perform(options)
        journey_id = options.fetch('journey_id')
        journey = Journey.find_by(id: journey_id)
        return false if journey.nil?

        puts "[SIDEKIQ][JourneyManagement][#{journey_id}][START]"

        start_time = Time.zone.now

        ret = JourneyManagement::ProcessJourneyService.new.call(journey: journey)

        puts "[SIDEKIQ][JourneyManagement][#{journey_id}][END] #{Time.zone.now - start_time}s"
      end
    end
  end
end

Additional context

[SIDEKIQ][JourneyManagement] number of messages in the log are incredible small. Like 10 processed in 5 minutes, where it should be thousands.

Worth noting that nothing has changed, the last release we made was last week and this suddenly started happening, this is blowing up our redis instance too as duplicates of this object are in the queue.

Gem:

gem 'sidekiq', '~> 6.1.2'
gem 'sidekiq-scheduler', '~> 2.2.2'
gem 'sidekiq-status', '~> 1.1.4'
gem 'sidekiq-unique-jobs', '~> 6.0.25'