From 89b12345bbca90e593e7f6b5e120320e41c29a9c Mon Sep 17 00:00:00 2001
From: cmrd Senya <senya@riseup.net>
Date: Tue, 9 Aug 2016 13:38:36 +0300
Subject: [PATCH] Rake task for legacy sidekiq queues

---
 lib/tasks/migrations.rake | 16 ++++++++++++++++
 1 file changed, 16 insertions(+)

diff --git a/lib/tasks/migrations.rake b/lib/tasks/migrations.rake
index 20d7d42d8..96342c76c 100644
--- a/lib/tasks/migrations.rake
+++ b/lib/tasks/migrations.rake
@@ -127,4 +127,20 @@ namespace :migrations do
       tag.destroy
     end
   end
+
+  LEGACY_QUEUES = %w(
+    maintenance dispatch delete_account http http_service export photos socket_webfinger mail receive_local receive
+  ).freeze
+
+  desc "Run sidekiq with old queues so it can finish deferred jobs"
+  task :run_legacy_queues do
+    queues_with_jobs = LEGACY_QUEUES.select {|queue| Sidekiq::Queue.new(queue).size > 0 }
+    if queues_with_jobs.empty?
+      puts "No jobs in legacy queues!"
+    else
+      puts "Launching sidekiq with queues: #{queues_with_jobs.join(', ')}"
+      queus_cli = queues_with_jobs.map {|queue| "-q #{queue}" }.join(" ")
+      system "bundle exec sidekiq #{queus_cli} -e #{Rails.env}"
+    end
+  end
 end