Open blackchestnut opened 6 years ago
queue = Sidekiq::Queue.new('queue_name') queue.select { |job| job.args.first['arguments'].include?('category') }.each(&:delete)
Notes
queue.size # => 508 queue.first.args[0]['job_class'] # => "Parsers::Pages::ProcessJob" queue.first.args[0]['job_id'] # => "1b8d73ea-bf29-4a2f-9488-d833b5f18f86"
Notes