Class: Smriti::DeleteViewJob

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

Overview

ActiveJob that handles deletion of PostgreSQL materialised views via Services::DeleteView.

This job mirrors CreateViewJob and RefreshViewJob: it times the run and persists lifecycle state in MatViewRun.

Examples:

Enqueue a delete job

Smriti::DeleteViewJob.perform_later(definition.id, cascade: true)

Inline run (test/dev)

Smriti::DeleteViewJob.new.perform(definition.id, false)

See Also:

Instance Attribute Summary collapse

Instance Method Summary collapse

Instance Attribute Details

#cascade ⇒ Boolean (readonly)

cascade flag for the service call

Returns:

  • (Boolean) 


32
33
34
 
# File 'app/jobs/smriti/delete_view_job.rb', line 32

def cascade
  @cascade
end

Instance Method Details

#perform(mat_view_definition_id, cascade_arg = nil, row_count_strategy_arg = nil) ⇒ Hash

Perform the job for the given materialised view definition.

Parameters:

  • mat_view_definition_id (Integer, String) —

    ID of MatViewDefinition.

  • cascade_arg (Boolean, String, Integer, Hash, nil) (defaults to: nil) —

    Cascade option.

  • 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.



58
59
60
61
62
63
64
65
 
# File 'app/jobs/smriti/delete_view_job.rb', line 58

def perform(mat_view_definition_id, cascade_arg = nil, row_count_strategy_arg = nil)
  definition = Smriti::MatViewDefinition.find(mat_view_definition_id)
  record_run(definition, :drop) do
    Smriti::Services::DeleteView.new(definition,
                                     cascade: cascade?(cascade_arg),
                                     row_count_strategy: normalize_strategy(row_count_strategy_arg)).call
  end
end