github-mirror/discourse
2
0
Fork 0
mirror of https://github.com/discourse/discourse.git synced 2025-06-06 23:07:28 +08:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

Allow multiple host when restricting Sidekiq queues.

Browse Source
This commit is contained in:
Guo Xiang Tan
2017-06-19 14:45:51 +09:00
parent be44e4b730
commit 7ea288140d
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
config/initializers/100-sidekiq.rb
View File

@ -23,7 +23,7 @@ if Sidekiq.server?
Rails.application.config.after_initialize do Rails.application.config.after_initialize do
scheduler_hostname = ENV["UNICORN_SCHEDULER_HOSTNAME"] scheduler_hostname = ENV["UNICORN_SCHEDULER_HOSTNAME"]
if !scheduler_hostname || scheduler_hostname == `hostname`.strip if !scheduler_hostname || scheduler_hostname.split(',').include?(`hostname`.strip)
require 'scheduler/scheduler' require 'scheduler/scheduler'
manager = Scheduler::Manager.new manager = Scheduler::Manager.new
Scheduler::Manager.discover_schedules.each do |schedule| Scheduler::Manager.discover_schedules.each do |schedule|

2
lib/demon/sidekiq.rb
View File

@ -37,7 +37,7 @@ class Demon::Sidekiq < Demon::Base
[['critical', 4], ['default', 2], ['low', 1]].each do |queue_name, weight| [['critical', 4], ['default', 2], ['low', 1]].each do |queue_name, weight|
custom_queue_hostname = ENV["UNICORN_SIDEKIQ_#{queue_name.upcase}_QUEUE_HOSTNAME"] custom_queue_hostname = ENV["UNICORN_SIDEKIQ_#{queue_name.upcase}_QUEUE_HOSTNAME"]
if !custom_queue_hostname || custom_queue_hostname == `hostname`.strip if !custom_queue_hostname || custom_queue_hostname.split(',').include?(`hostname`.strip)
options << "-q" options << "-q"
options << "#{queue_name},#{weight}" options << "#{queue_name},#{weight}"
end end