Class: Smriti::RefreshViewJob

Inherits:
ApplicationJob show all
Defined in:
app/jobs/smriti/refresh_view_job.rb

Overview

ActiveJob that handles REFRESH MATERIALIZED VIEW for a given MatViewDefinition.

The job mirrors CreateViewJob's lifecycle: it measures duration and persists state in MatViewRun.

The actual refresh implementation is delegated based on definition.refresh_strategy:

Row count reporting can be controlled via row_count_strategy:

  • :estimated (default) - fast, approximate via reltuples
  • :exact - accurate COUNT(*)
  • nil - skip counting

Examples:

Enqueue a refresh with exact row count

Smriti::RefreshViewJob.perform_later(definition.id, :exact)

Enqueue using keyword-hash form

Smriti::RefreshViewJob.perform_later(definition.id, row_count_strategy: :estimated)

See Also:

Instance Method Summary collapse

Instance Method Details

#perform(mat_view_definition_id, row_count_strategy_arg = nil) ⇒ Hash

Perform the refresh job for the given materialised view definition.

Parameters:

  • mat_view_definition_id (Integer, String) —

    ID of MatViewDefinition.

  • row_count_strategy_arg (:Symbol, String) (defaults to: nil) —

    One of: :estimated, :exact, :none or nil.

Returns:

  • (Hash) —

    Serialized ServiceResponse#to_h:

    • :status [Symbol]
    • :error [String, nil]
    • :duration_ms [Integer]
    • :meta [Hash]

Raises:

  • (StandardError) —

    Re-raised on unexpected failure after marking the run failed.



66
67
68
69
70
71
 
# File 'app/jobs/smriti/refresh_view_job.rb', line 66

def perform(mat_view_definition_id, row_count_strategy_arg = nil)
  definition = Smriti::MatViewDefinition.find(mat_view_definition_id)
  record_run(definition, :refresh) do
    service(definition).new(definition, row_count_strategy: normalize_strategy(row_count_strategy_arg)).call
  end
end