1 files changed, 11 insertions, 4 deletions
diff --git a/lib/tasks/gitlab/sidekiq.rake b/lib/tasks/gitlab/sidekiq.rake
index 10492e183c5..dc472305304 100644
--- a/lib/tasks/gitlab/sidekiq.rake
+++ b/lib/tasks/gitlab/sidekiq.rake
@@ -10,15 +10,22 @@ namespace :gitlab do
       desc 'GitLab | Sidekiq | Migrate jobs in the scheduled set to new queue names'
       task schedule: :environment do
         ::Gitlab::SidekiqMigrateJobs
-          .new('schedule', logger: Logger.new($stdout))
-          .execute(::Gitlab::SidekiqConfig.worker_queue_mappings)
+          .new(::Gitlab::SidekiqConfig.worker_queue_mappings, logger: Logger.new($stdout) )
+          .migrate_set('schedule')
       end
 
       desc 'GitLab | Sidekiq | Migrate jobs in the retry set to new queue names'
       task retry: :environment do
         ::Gitlab::SidekiqMigrateJobs
-          .new('retry', logger: Logger.new($stdout))
-          .execute(::Gitlab::SidekiqConfig.worker_queue_mappings)
+          .new(::Gitlab::SidekiqConfig.worker_queue_mappings, logger: Logger.new($stdout) )
+          .migrate_set('retry')
+      end
+
+      desc 'GitLab | Sidekiq | Migrate jobs in queues outside of routing rules'
+      task queued: :environment do
+        ::Gitlab::SidekiqMigrateJobs
+          .new(::Gitlab::SidekiqConfig.worker_queue_mappings, logger: Logger.new($stdout) )
+          .migrate_queues
       end
     end