See if a Sidekiq job is queued or running

sidekiq_already_running.rb

class DaWorker
  include Sidekiq::Worker
  
  def perform
    sleep(10)
  end
  
  class << self
    def queue_name
      sidekiq_options_hash["queue"].to_s || "default"
    end

    def queued?(*args)
      queue = Sidekiq::Queue.new(queue_name)
      queue.any? do |job|
        job.klass == self.name && job.args == args
      end
    end

    def running?(*args)
      workers = Sidekiq::Workers.new
      workers.to_a.any? do |worker_name, tid, work|
        payload = work["payload"]
        next unless payload.present?
        payload["queue"] == queue_name and payload["class"] == self.name && payload["args"] == args
      end
    end

    def queued_or_running?(*args)
      running?(*args) or queued?(*args)
    end
  end
end