app/models/concerns/external_services/action.rb in external_services-0.5.0 vs app/models/concerns/external_services/action.rb in external_services-0.5.1

@@ -34,13 +34,11 @@
       [QUEUE_PREFIX, queue].join('__')
     end
 
     module ClassMethods
       def clear_sidekiq_queues
-        Sidekiq.redis do |conn|
-          conn.keys.select { |k| k.include?(QUEUE_PREFIX) }.each do |k|
-            conn.del k
-          end
+        Sidekiq::Queue.all.each do |queue|
+          queue.clear if queue.name.include?(QUEUE_PREFIX)
         end
       end
 
       def perform_unprocessed
         Rails.logger.info "Running unprocessed #{self.class.name.demodulize} api actions..."