Class: MatViews::DeleteViewJob

Inherits:
ApplicationJob show all
Defined in:
app/jobs/mat_views/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

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

Inline run (test/dev)

MatViews::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/mat_views/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/mat_views/delete_view_job.rb', line 58

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