Sha256: 62fefdfc515164cca2d43327bb6f1def7827c62a697f4580f1a04ebb5c3dc2eb

Contents?: true

Size: 937 Bytes

Versions: 25

Compression:

Stored size: 937 Bytes

Contents

# frozen_string_literal: true

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

25 entries across 25 versions & 1 rubygems

Version Path
renalware-core-2.0.43 app/jobs/renalware/reporting/refresh_audit_data_job.rb
renalware-core-2.0.42 app/jobs/renalware/reporting/refresh_audit_data_job.rb
renalware-core-2.0.41 app/jobs/renalware/reporting/refresh_audit_data_job.rb
renalware-core-2.0.40 app/jobs/renalware/reporting/refresh_audit_data_job.rb
renalware-core-2.0.39 app/jobs/renalware/reporting/refresh_audit_data_job.rb
renalware-core-2.0.38 app/jobs/renalware/reporting/refresh_audit_data_job.rb
renalware-core-2.0.37 app/jobs/renalware/reporting/refresh_audit_data_job.rb
renalware-core-2.0.36 app/jobs/renalware/reporting/refresh_audit_data_job.rb
renalware-core-2.0.35 app/jobs/renalware/reporting/refresh_audit_data_job.rb
renalware-core-2.0.34 app/jobs/renalware/reporting/refresh_audit_data_job.rb
renalware-core-2.0.33 app/jobs/renalware/reporting/refresh_audit_data_job.rb
renalware-core-2.0.32 app/jobs/renalware/reporting/refresh_audit_data_job.rb
renalware-core-2.0.31 app/jobs/renalware/reporting/refresh_audit_data_job.rb
renalware-core-2.0.30 app/jobs/renalware/reporting/refresh_audit_data_job.rb
renalware-core-2.0.28 app/jobs/renalware/reporting/refresh_audit_data_job.rb
renalware-core-2.0.27 app/jobs/renalware/reporting/refresh_audit_data_job.rb
renalware-core-2.0.26 app/jobs/renalware/reporting/refresh_audit_data_job.rb
renalware-core-2.0.25 app/jobs/renalware/reporting/refresh_audit_data_job.rb
renalware-core-2.0.24 app/jobs/renalware/reporting/refresh_audit_data_job.rb
renalware-core-2.0.23 app/jobs/renalware/reporting/refresh_audit_data_job.rb