Sha256: 4d1afb0cbd28ef71cdffefd1b21ac513e320ef18163309bbc1a7151b685616dc

Contents?: true

Size: 906 Bytes

Versions: 30

Compression:

Stored size: 906 Bytes

Contents

require_dependency "renalware/reporting"

module Renalware
  module Reporting
    class RefreshAuditDataJob < ApplicationJob
      queue_as :reporting

      # :reek:UtilityFunction
      def perform(audit)
        if audit.materialized?
          refresh_materialized_view_associated_with_audit(audit)
          update_audit_refreshment_date(audit)
        else
          Rails.logger.warn("Cannot refresh an view that is not materialized: #{audit.view_name}")
        end
      end

      private

      def refresh_materialized_view_associated_with_audit(audit)
        Scenic.database.refresh_materialized_view(audit.view_name,
                                                  concurrently: false,
                                                  cascade: false)
      end

      def update_audit_refreshment_date(audit)
        audit.update!(refreshed_at: Time.zone.now)
      end
    end
  end
end

Version data entries

30 entries across 30 versions & 1 rubygems

Version Path
renalware-core-2.0.16 app/jobs/renalware/reporting/refresh_audit_data_job.rb
renalware-core-2.0.15 app/jobs/renalware/reporting/refresh_audit_data_job.rb
renalware-core-2.0.14 app/jobs/renalware/reporting/refresh_audit_data_job.rb
renalware-core-2.0.13 app/jobs/renalware/reporting/refresh_audit_data_job.rb
renalware-core-2.0.12 app/jobs/renalware/reporting/refresh_audit_data_job.rb
renalware-core-2.0.11 app/jobs/renalware/reporting/refresh_audit_data_job.rb
renalware-core-2.0.9 app/jobs/renalware/reporting/refresh_audit_data_job.rb
renalware-core-2.0.8 app/jobs/renalware/reporting/refresh_audit_data_job.rb
renalware-core-2.0.7 app/jobs/renalware/reporting/refresh_audit_data_job.rb
renalware-core-2.0.5 app/jobs/renalware/reporting/refresh_audit_data_job.rb
renalware-core-2.0.4 app/jobs/renalware/reporting/refresh_audit_data_job.rb
renalware-core-2.0.3 app/jobs/renalware/reporting/refresh_audit_data_job.rb
renalware-core-2.0.2 app/jobs/renalware/reporting/refresh_audit_data_job.rb
renalware-core-2.0.1 app/jobs/renalware/reporting/refresh_audit_data_job.rb
renalware-core-2.0.0 app/jobs/renalware/reporting/refresh_audit_data_job.rb
renalware-core-2.0.0.pre.rc13 app/jobs/renalware/reporting/refresh_audit_data_job.rb
renalware-core-2.0.0.pre.rc11 app/jobs/renalware/reporting/refresh_audit_data_job.rb
renalware-core-2.0.0.pre.rc10 app/jobs/renalware/reporting/refresh_audit_data_job.rb
renalware-core-2.0.0.pre.rc9 app/jobs/renalware/reporting/refresh_audit_data_job.rb
renalware-core-2.0.0.pre.rc8 app/jobs/renalware/reporting/refresh_audit_data_job.rb