Sha256: 5f882732d8350e10001d07613b1d0b83f57d6125c78a07be400055704acac74c
Contents?: true
Size: 1.46 KB
Versions: 10
Compression:
Stored size: 1.46 KB
Contents
# frozen_string_literal: true
# Job to run monitoring tests
module QaServer
class MonitorTestsJob < ApplicationJob
include QaServer::AuthorityValidationBehavior
queue_as :default
class_attribute :scenario_run_registry_class
self.scenario_run_registry_class = QaServer::ScenarioRunRegistry
def perform
# checking active_job_id? prevents race conditions for long running jobs
run_tests if QaServer::JobIdCache.active_job_id?(job_key: job_key, job_id: job_id, expires_in: 2.hours)
end
private
def run_tests
QaServer.config.monitor_logger.debug("(#{self.class}##{__method__}-#{job_id}) RUNNING monitoring tests")
validate(authorities_list)
log_results(authorities_list, status_log.to_a)
scenario_run_registry_class.save_run(scenarios_results: status_log.to_a)
QaServer.config.monitor_logger.debug("(#{self.class}##{__method__}-#{job_id}) COMPLETED monitoring tests")
QaServer.config.performance_cache.write_all # write out cache after completing tests
QaServer::JobIdCache.reset_job_id(job_key: job_key)
end
def log_results(authorities_list, results)
QaServer.config.monitor_logger.warn("(#{self.class}##{__method__}-#{job_id}) authorities_list is empty") if authorities_list&.empty?
QaServer.config.monitor_logger.warn("(#{self.class}##{__method__}-#{job_id}) test results are empty") if results&.empty?
end
def job_key
"QaServer::MonitorTestsJob--job_id"
end
end
end
Version data entries
10 entries across 10 versions & 1 rubygems