Sha256: 177b68d55975d3c658597f4ebb70258eed3b17653e39e29dd22a1e7a9dd50d65
Contents?: true
Size: 627 Bytes
Versions: 116
Compression:
Stored size: 627 Bytes
Contents
# frozen_string_literal: true
#
# Refresh a materialized view asynchronously via the delayed_job queue.
# If no view_name supplied, refresh all materialized views
#
class RefreshMaterializedViewJob < ApplicationJob
queue_with_priority 6
def perform(view_name: nil)
conn = ActiveRecord::Base.connection
if view_name.present?
Rails.logger.info("Refreshing materialized view #{view_name}...")
conn.execute("REFRESH MATERIALIZED VIEW #{view_name};")
else
Rails.logger.info("Refreshing all materialized views...")
conn.execute("SELECT refresh_all_matierialized_views();")
end
end
end
Version data entries
116 entries across 116 versions & 1 rubygems