feat: Add task for expire all resque locks

https://jira.railsc.ru/browse/PC4-21159

lib/resque/integration/engine.rb

@@ -1,5 +1,3 @@
-# coding: utf-8
-
 require 'redis'
 require 'redis/version'
 require 'rails/engine'
@@ -12,6 +10,7 @@ class Engine < Rails::Engine
     rake_tasks do
       load 'resque/integration/tasks/hooks.rake'
       load 'resque/integration/tasks/resque.rake'
+      load 'resque/integration/tasks/lock.rake'
     end
 
     # Читает конфиг-файлы config/resque.yml и config/resque.local.yml,

lib/resque/integration/tasks/lock.rake

@@ -0,0 +1,37 @@
+require 'resque/integration/unique'
+
+namespace :resque do
+  namespace :lock do
+    task expire_all: :environment do
+      puts "Start expiring all resque locks"
+
+      redis = ::Resque.redis
+      cursor = 0
+      batch_size = 10_000
+      timeout = ::Resque::Integration::Unique::LOCK_TIMEOUT
+      count = 0
+      pattern = "lock:*"
+
+      loop do
+        cursor, keys = redis.scan(cursor, count: batch_size, match: pattern)
+        cursor = cursor.to_i
+
+        unless keys.empty?
+          redis.pipelined do
+            keys.each do |key|
+              redis.expire(key, timeout)
+            end
+          end
+
+          count += keys.size
+          puts "Expired #{count}..."
+        end
+
+        break if cursor.zero?
+      end
+
+      puts "Expired total #{count} keys."
+      puts "Done."
+    end
+  end
+end