|
require "sidekiq/sd_notify"
|
|
|
|
rails_root = Dir.pwd
|
|
|
|
app_file = File.expand_path('./config/application', rails_root)
|
|
require app_file
|
|
|
|
::Rails.application.dynflow.config.lazy_initialization = true
|
|
::Rails.application.dynflow.config.on_init(false) do |world|
|
|
# Loading and initializing of all gettext languages takes about 100ms per language
|
|
# in development environment and little less on production. Let's eager load languages
|
|
# but only for production.
|
|
Foreman::Gettext::Support.human_available_locales
|
|
end
|
|
|
|
rails_env_file = File.expand_path('./config/environment.rb', rails_root)
|
|
require rails_env_file
|
|
|
|
if Sidekiq[:queues].include?("dynflow_orchestrator")
|
|
Sidekiq[:dynflow_executor] = true
|
|
::Rails.application.dynflow.executor!
|
|
elsif (Sidekiq[:queues] - ['dynflow_orchestrator']).any?
|
|
::Rails.application.dynflow.config.remote = true
|
|
end
|
|
|
|
::Rails.application.dynflow.config.on_init(false) do |world|
|
|
Sidekiq[:dynflow_world] = world
|
|
end
|
|
|
|
# To be able to ensure ordering, dynflow requires that there is only one
|
|
# orchestrator active at the same time.
|
|
# This is enforced by orchestrators contending a lock in redis, calls to
|
|
# dynflow.initialize! block until the lock is acquired by the current process.
|
|
# To play nice with sd_notify, we need to mark the process as ready before it
|
|
# attempts to acquire the lock.
|
|
if Sidekiq[:dynflow_executor]
|
|
msg = 'orchestrator in passive mode'
|
|
Rails.logger.info(msg)
|
|
Sidekiq::SdNotify.status(msg)
|
|
Sidekiq::SdNotify.ready
|
|
end
|
|
::Rails.application.dynflow.initialize!
|
|
msg = "Everything ready for world: #{::Rails.application.dynflow.world.id}"
|
|
Rails.logger.info(msg)
|
|
Sidekiq::SdNotify.status(msg)
|
