How to query Rails Sidekiq queues by Job class, queue name and arguments?-CodePudding

I have to check if the same job has already been added to the queue before enqueue again. Currently I use this code but it's very inefficient because it loads all object into memory. Is there a way to query like a normal active record?

Ideally, I would something like Sidekiq::Queue.where(job_class: "SyncJob", queue_name:"high", arguments: [1,2,3])

   def list_queued_jobs(job_class, queue_name,  arguments)
        found_jobs = []
        queues = Sidekiq::Queue.all
        queues.each do |queue|
            queue.each do |job|
                job.args.each do |arg|
                    if arg['job_class'].to_s == job_class.to_s && arg['queue_name'] == queue_name && ActiveJob::Arguments.deserialize(arg['arguments']) == arguments
                        found_jobs << job
                    end
                end
            end
        end
        return found_jobs
    end

CodePudding user response：

There is no out-of-the-box solution, but there is a simpler way to determine if a job's been already queued (true/false):

def in_queues?(job_class, queue_name,  arguments = [])
  Sidekiq::Queue.new(queue_name).any? do |job|
    job_class == job.klass && job.args == arguments
  end
end

Keep in mind that sidekiq arguments are presented as an array. For example, if you call your job like:

SyncJob.perform_async([1, 2, 3])

then you check that it's been queued as follows:

in_queues?("SyncJob", "high", [[1, 2, 3]])