From 272be6ab6691b55de652639318d45336093e3e1c Mon Sep 17 00:00:00 2001 From: dtaniwaki Date: Mon, 7 Mar 2016 22:50:30 -0800 Subject: [PATCH] Allow hash for sidekiq queue --- lib/capistrano/tasks/monit.rake | 1 + lib/capistrano/tasks/sidekiq.rake | 1 + 2 files changed, 2 insertions(+) diff --git a/lib/capistrano/tasks/monit.rake b/lib/capistrano/tasks/monit.rake index 9987d68..589ed74 100644 --- a/lib/capistrano/tasks/monit.rake +++ b/lib/capistrano/tasks/monit.rake @@ -109,6 +109,7 @@ namespace :sidekiq do def sidekiq_queues Array(fetch(:sidekiq_queue)).map do |queue| + queue = "#{queue[0]},#{queue[1]}" if queue.is_a?(Array) "--queue #{queue}" end.join(' ') end diff --git a/lib/capistrano/tasks/sidekiq.rake b/lib/capistrano/tasks/sidekiq.rake index 4833e32..4ed7f8c 100644 --- a/lib/capistrano/tasks/sidekiq.rake +++ b/lib/capistrano/tasks/sidekiq.rake @@ -95,6 +95,7 @@ namespace :sidekiq do args.push "--require #{fetch(:sidekiq_require)}" if fetch(:sidekiq_require) args.push "--tag #{fetch(:sidekiq_tag)}" if fetch(:sidekiq_tag) Array(fetch(:sidekiq_queue)).each do |queue| + queue = "#{queue[0]},#{queue[1]}" if queue.is_a?(Array) args.push "--queue #{queue}" end args.push "--config #{fetch(:sidekiq_config)}" if fetch(:sidekiq_config)