measure_calculation_job.rb in quality-measure-engine-3.1.0

- old
+ new

@@ -17,11 +17,10 @@
         @options = options
         @options.merge! @quality_report.attributes
       end
 
       def perform
-
         if !@quality_report.calculated?
           map = QME::MapReduce::Executor.new(@quality_report.measure_id,@quality_report.sub_id, @options.merge('start_time' => Time.now.to_i))
           if !@quality_report.patients_cached?
             tick('Starting MapReduce')
             map.map_records_into_measure_groups(@options['prefilter'])
@@ -40,9 +39,10 @@
           end
           @quality_report.save
           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]}")
           QME::QualityReport.queue_staged_rollups(@quality_report.measure_id,@quality_report.sub_id,@quality_report.effective_date)
         end
+        @quality_report
       end
 
       def completed(message)
         @quality_report.status["state"] = "completed"
         @quality_report.status["log"] << message