Module: Appsignal::Integrations::QuePlugin

Defined in:
lib/appsignal/integrations/que.rb

Instance Method Summary collapse

Instance Method Details

#_run ⇒ Object 



6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
 
# File 'lib/appsignal/integrations/que.rb', line 6

def _run(*)
  local_attrs = respond_to?(:que_attrs) ? que_attrs : attrs
  env = {
    :metadata    => {
      :id        => local_attrs[:job_id] || local_attrs[:id],
      :queue     => local_attrs[:queue],
      :run_at    => local_attrs[:run_at].to_s,
      :priority  => local_attrs[:priority],
      :attempts  => local_attrs[:error_count].to_i
    },
    :params => local_attrs[:args]
  }

  request = Appsignal::Transaction::GenericRequest.new(env)

  transaction = Appsignal::Transaction.create(
    SecureRandom.uuid,
    Appsignal::Transaction::BACKGROUND_JOB,
    request
  )

  begin
    Appsignal.instrument("perform_job.que") { super }
  rescue Exception => error # rubocop:disable Lint/RescueException
    transaction.set_error(error)
    raise error
  ensure
    transaction.set_action_if_nil "#{local_attrs[:job_class]}#run"
    Appsignal::Transaction.complete_current!
  end
end