Sha256: 118e76e6f09420318cda4bd3f9974e1ce95b925342b2b0b5f4dad3da4a96c738
Contents?: true
Size: 1.44 KB
Versions: 26
Compression:
Stored size: 1.44 KB
Contents
# DelayedJob is a unique diagnostic that creates a series of delayed jobs
# in the hopes that enough nodes will touch these jobs to determine
# if delayed job workers are running the latest application version
#
# `DELAYED_VER` environment variable should be set in the
# delayed jobs initializer.
#
module Marty::Diagnostic; class DelayedJobVersion < Base
self.aggregatable = false
def self.generate
raise 'DelayedJob cannot be called with local scope.' if scope == 'local'
raise 'DELAYED_VER environment variable has not been initialized.' if
ENV['DELAYED_VER'].nil?
total_workers = Node.get_target_connections('delayed').count
raise 'No delayed jobs are running.' if total_workers.zero?
# we will only iterate by half of the total delayed workers to avoid
# excess use of delayed job time
total_workers = (total_workers / 2).zero? ? 1 : total_workers / 2
d_engine = Marty::ScriptSet.new.get_engine('Diagnostics')
res = d_engine.
evaluate('VersionDelay', 'result', 'count' => total_workers - 1)
# merge results, remove duplicates, and construct "aggregate" object
res.each_with_object({}) do |r, hash|
hash[r[0]] ||= []
hash[r[0]] << r[1]
end.map do |node, result|
versions = result.uniq
status = versions.count == 1 && versions[0] == ENV['DELAYED_VER']
{ node => { 'Version' => create_info(versions.join("\n"), status) } }
end.reduce(:deep_merge)
end
end
end
Version data entries
26 entries across 26 versions & 1 rubygems