diff options
Diffstat (limited to 'lib/tasks/gitlab/sidekiq.rake')
-rw-r--r-- | lib/tasks/gitlab/sidekiq.rake | 15 |
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 |