Sha256: 673b54a4a2e2b19ca80b54b7b807aeafcb68312b09bed051c5619372a31f3419

Contents?: true

Size: 1.57 KB

Versions: 63

Compression:

Stored size: 1.57 KB

Contents

module Appsignal
  class Hooks
    class DelayedJobPlugin < ::Delayed::Plugin
      extend Appsignal::Hooks::Helpers

      callbacks do |lifecycle|
        lifecycle.around(:invoke_job) do |job, &block|
          invoke_with_instrumentation(job, block)
        end

        lifecycle.after(:execute) do |execute|
          Appsignal.stop('delayed job')
        end
      end

      def self.invoke_with_instrumentation(job, block)
        if job.respond_to?(:payload_object)
          # Direct Delayed Job
          class_and_method_name = extract_value(job.payload_object, :appsignal_name, job.name)
          class_name, method_name = class_and_method_name.split('#')
          args = extract_value(job.payload_object, :args, {})
          job_data = job
        elsif job.respond_to?(:job_data)
          # Via ActiveJob
          class_name, method_name = job.job_data[:name].split('#')
          args = job.job_data[:args] || {}
          job_data = job.job_data
        end

        Appsignal.monitor_transaction(
          'perform_job.delayed_job',
          :class    => class_name,
          :method   => method_name,
          :metadata => {
            :id       => extract_value(job_data, :id, nil, true),
            :queue    => extract_value(job_data, :queue),
            :priority => extract_value(job_data, :priority, 0),
            :attempts => extract_value(job_data, :attempts, 0)
          },
          :params      => format_args(args),
          :queue_start => extract_value(job_data, :created_at)
        ) do
          block.call(job)
        end
      end
    end
  end
end

Version data entries

63 entries across 63 versions & 1 rubygems

Version Path
appsignal-2.0.6 lib/appsignal/integrations/delayed_job_plugin.rb
appsignal-2.0.5 lib/appsignal/integrations/delayed_job_plugin.rb
appsignal-2.0.5.beta.1 lib/appsignal/integrations/delayed_job_plugin.rb
appsignal-2.1.0.alpha.3 lib/appsignal/integrations/delayed_job_plugin.rb
appsignal-2.1.0.alpha.2 lib/appsignal/integrations/delayed_job_plugin.rb
appsignal-2.1.0.alpha.1 lib/appsignal/integrations/delayed_job_plugin.rb
appsignal-2.0.4 lib/appsignal/integrations/delayed_job_plugin.rb
appsignal-2.0.3 lib/appsignal/integrations/delayed_job_plugin.rb
appsignal-2.0.2 lib/appsignal/integrations/delayed_job_plugin.rb
appsignal-2.0.1 lib/appsignal/integrations/delayed_job_plugin.rb
appsignal-2.0.0 lib/appsignal/integrations/delayed_job_plugin.rb
appsignal-2.0.0.beta.1 lib/appsignal/integrations/delayed_job_plugin.rb
appsignal-1.4.0.beta.1 lib/appsignal/integrations/delayed_job_plugin.rb
appsignal-1.3.6 lib/appsignal/integrations/delayed_job_plugin.rb
appsignal-1.3.6.beta.1 lib/appsignal/integrations/delayed_job_plugin.rb
appsignal-1.3.5 lib/appsignal/integrations/delayed_job_plugin.rb
appsignal-1.3.5.beta.1 lib/appsignal/integrations/delayed_job_plugin.rb
appsignal-1.3.4 lib/appsignal/integrations/delayed_job_plugin.rb
appsignal-1.3.3 lib/appsignal/integrations/delayed_job_plugin.rb
appsignal-1.4.0.alpha.2 lib/appsignal/integrations/delayed_job_plugin.rb