Sha256: 13fc2a9caae05d882186583fdf0080cd594d3d34ce94b116362e70b77f0848f9
Contents?: true
Size: 1.95 KB
Versions: 7
Compression:
Stored size: 1.95 KB
Contents
module QME
module MapReduce
# A delayed_job that allows for measure calculation by a delayed_job worker. Can be created as follows:
#
# Delayed::Job.enqueue QME::MapRedude::MeasureCalculationJob.new(:measure_id => '0221', :sub_id => 'a', :effective_date => 1291352400, :test_id => xyzzy)
#
# MeasureCalculationJob will check to see if a measure has been calculated before running the calculation. It does
# this by creating a QME::QualityReport and asking if it has been calculated. If so, it will complete the job without
# running the MapReduce job.
#
# When a measure needs calculation, the job will create a QME::MapReduce::Executor and interact with it to calculate
# the report.
class MeasureCalculationJob
attr_accessor :test_id, :measure_id, :sub_id, :effective_date, :filters
def initialize(options)
@measure_id = options['measure_id']
@sub_id = options['sub_id']
@options = options
end
def perform
qr = QualityReport.new(@measure_id, @sub_id, @options)
if qr.calculated?
completed("#{@measure_id}#{@sub_id} has already been calculated")
else
map = QME::MapReduce::Executor.new(@measure_id, @sub_id, @options.merge('start_time' => Time.now.to_i))
if !qr.patients_cached?
tick('Starting MapReduce')
map.map_records_into_measure_groups
tick('MapReduce complete')
end
tick('Calculating group totals')
result = map.count_records_in_measure_groups
completed("#{@measure_id}#{@sub_id}: p#{result[QME::QualityReport::POPULATION]}, d#{result[QME::QualityReport::DENOMINATOR]}, n#{result[QME::QualityReport::NUMERATOR]}, excl#{result[QME::QualityReport::EXCLUSIONS]}, excep#{result[QME::QualityReport::EXCEPTIONS]}")
end
end
def completed(message)
end
def tick(message)
end
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems