Sha256: 2214ee54ea16281b521246a68ddcc296cdebb4fc861fd4d06852d2fee81c1ea8
Contents?: true
Size: 1.88 KB
Versions: 10
Compression:
Stored size: 1.88 KB
Contents
# frozen_string_literal: true
# Job to generate the performance year graph covering the last 12 months.
module QaServer
class PerformanceYearGraphJob < ApplicationJob
include QaServer::PerformanceHistoryDataKeys
queue_as :default
class_attribute :authority_list_class, :graph_data_service, :graphing_service
self.authority_list_class = QaServer::AuthorityListerService
self.graph_data_service = QaServer::PerformanceGraphDataService
self.graphing_service = QaServer::PerformanceGraphingService
def perform
# checking active_job_id? prevents race conditions for long running jobs
generate_graphs_for_authorities if QaServer::JobIdCache.active_job_id?(job_key: job_key, job_id: job_id)
end
private
def generate_graphs_for_authorities
QaServer.config.monitor_logger.debug("(#{self.class}-#{job_id}) - GENERATING performance year graph")
auths = authority_list_class.authorities_list
generate_graphs_for_authority(authority_name: ALL_AUTH) # generates graph for all authorities
auths.each { |authname| generate_graphs_for_authority(authority_name: authname) }
QaServer.config.monitor_logger.debug("(#{self.class}-#{job_id}) COMPLETED performance year graph generation")
QaServer::JobIdCache.reset_job_id(job_key: job_key)
end
def generate_graphs_for_authority(authority_name:)
[SEARCH, FETCH, ALL_ACTIONS].each_with_object({}) do |action, hash|
hash[action] = generate_12_month_graph(authority_name: authority_name, action: action)
end
end
def generate_12_month_graph(authority_name:, action:)
data = graph_data_service.calculate_last_12_months(authority_name: authority_name, action: action)
graphing_service.generate_year_graph(authority_name: authority_name, action: action, data: data)
end
def job_key
"QaServer::PerformanceYearGraphJob--job_id"
end
end
end
Version data entries
10 entries across 10 versions & 1 rubygems