Module: Appsignal::Hooks::ActiveJobHook::ActiveJobClassInstrumentation

Defined in:

lib/appsignal/hooks/active_job.rb

Instance Method Summary

• #execute(job) ⇒ Object

Instance Method Details

#execute(job) ⇒ Object

# File 'lib/appsignal/hooks/active_job.rb', line 224

def execute(job)
  enqueued_at = job["enqueued_at"]
  queue_start = Time.parse(enqueued_at) if enqueued_at
  queue_time =
    if queue_start
      time_now = Time.now.utc
      # Calculate queue time and store it as milliseconds
      (time_now - queue_start) * 1_000
    end

  job_status = nil
  has_wrapper_transaction = Appsignal::Transaction.current?
  transaction =
    if has_wrapper_transaction
      Appsignal::Transaction.current
    else
      # No standalone integration started before ActiveJob integration.
      # We don't have a separate integration for this QueueAdapter like
      # we do for Sidekiq.
      #
      # Prefer job_id from provider, instead of ActiveJob's internal ID.
      Appsignal::Transaction.create(Appsignal::Transaction::BACKGROUND_JOB)
    end

  begin
    transaction.add_params_if_nil(job["arguments"])

    transaction_tags = ActiveJobHelpers.transaction_tags_for(job)
    transaction.add_tags(transaction_tags)

    transaction.set_action(ActiveJobHelpers.action_name(job))

    super
  rescue Exception => exception
    job_status = :failed
    transaction_set_error(transaction, exception)
    raise exception
  ensure
    if transaction
      # Present in Rails 6 and up
      transaction.set_queue_start((queue_start.to_f * 1_000).to_i) if queue_start

      unless has_wrapper_transaction
        # Only complete transaction if ActiveJob is not wrapped in
        # another supported integration, such as Sidekiq.
        Appsignal::Transaction.complete_current!
      end
    end

    metrics = ActiveJobHelpers.metrics_for(job)
    metrics.each do |(metric_name, tags)|
      if job_status
        ActiveJobHelpers.increment_counter metric_name, 1,
          tags.merge(:status => job_status)
      end
      ActiveJobHelpers.increment_counter metric_name, 1,
        tags.merge(:status => :processed)
    end

    queue_name = job["queue_name"]
    if queue_time && queue_name
      ActiveJobHelpers.add_distribution_value(
        "queue_time",
        queue_time,
        :queue => queue_name
      )
    end
  end
end