diff --git a/config/initializers/sidekiq.rb b/config/initializers/sidekiq.rb index a7f9cfa6e..23eebfa1e 100644 --- a/config/initializers/sidekiq.rb +++ b/config/initializers/sidekiq.rb @@ -1,4 +1,8 @@ -if ENV.has_key?('REDIS_SIDEKIQ_SENTINELS') +SIDEKIQ_ENABLED = ENV.key?('REDIS_SIDEKIQ_SENTINELS') || ENV.key?('REDIS_URL') || ENV['RAILS_QUEUE_ADAPTER'] == 'sidekiq' + +return if !SIDEKIQ_ENABLED + +sidekiq_redis = if ENV.key?('REDIS_SIDEKIQ_SENTINELS') name = ENV.fetch('REDIS_SIDEKIQ_MASTER') username = ENV.fetch('REDIS_SIDEKIQ_USERNAME') password = ENV.fetch('REDIS_SIDEKIQ_PASSWORD') @@ -7,37 +11,30 @@ if ENV.has_key?('REDIS_SIDEKIQ_SENTINELS') .map { URI.parse(_1) } .map { { host: _1.host, port: _1.port, username:, password: } } - Sidekiq.configure_server do |config| - config.redis = { - name:, - sentinels:, - username:, - password:, - role: :master - } + { + name:, + sentinels:, + username:, + password:, + role: :master + } +else + {} # default config from REDIS_URL +end - if ENV['PROMETHEUS_EXPORTER_ENABLED'] == 'enabled' - Yabeda.configure! - Yabeda::Prometheus::Exporter.start_metrics_server! - end +Sidekiq.configure_server do |config| + config.redis = sidekiq_redis - if ENV['SKIP_RELIABLE_FETCH'].blank? - Sidekiq::ReliableFetch.setup_reliable_fetch!(config) - end - - config.capsule('api_entreprise') do |cap| - cap.concurrency = 1 - cap.queues = ['api_entreprise'] - end + if ENV['PROMETHEUS_EXPORTER_ENABLED'] == 'enabled' + Yabeda.configure! + Yabeda::Prometheus::Exporter.start_metrics_server! end - Sidekiq.configure_client do |config| - config.redis = { - name:, - sentinels:, - username:, - password:, - role: :master - } + if ENV['SKIP_RELIABLE_FETCH'].blank? + Sidekiq::ReliableFetch.setup_reliable_fetch!(config) end end + +Sidekiq.configure_client do |config| + config.redis = sidekiq_redis +end diff --git a/config/initializers/transition_to_sidekiq.rb b/config/initializers/transition_to_sidekiq.rb index 2c1c95403..f6070d1fd 100644 --- a/config/initializers/transition_to_sidekiq.rb +++ b/config/initializers/transition_to_sidekiq.rb @@ -1,5 +1,3 @@ -SIDEKIQ_ENABLED = ENV.has_key?('REDIS_SIDEKIQ_SENTINELS') || ENV.has_key?('REDIS_URL') - if Rails.env.production? && SIDEKIQ_ENABLED ActiveSupport.on_load(:after_initialize) do class ActiveStorage::PurgeJob < ActiveStorage::BaseJob