Contents

# frozen_string_literal: true
require "delayed_job"

module Sentry
  module DelayedJob
    class Plugin < ::Delayed::Plugin
      callbacks do |lifecycle|
        lifecycle.around(:invoke_job) do |job, *args, &block|
          Sentry.with_scope do |scope|
            scope.set_extras(**generate_extra(job))
            scope.set_tags("delayed_job.queue" => job.queue, "delayed_job.id" => job.id)

            begin
              block.call(job, *args)
            rescue Exception => e
              Sentry::DelayedJob.capture_exception(e, hint: { background: false })

              raise
            end
          end
        end
      end

      def self.generate_extra(job)
        extra = {
          "delayed_job.id": job.id,
          "delayed_job.priority": job.priority,
          "delayed_job.attempts": job.attempts,
          "delayed_job.run_at": job.run_at,
          "delayed_job.locked_at": job.locked_at,
          "delayed_job.locked_by": job.locked_by,
          "delayed_job.queue": job.queue,
          "delayed_job.created_at": job.created_at,
          "delayed_job.last_error": job.last_error&.byteslice(0..1000),
          "delayed_job.handler": job.handler&.byteslice(0..1000)
        }

        if job.payload_object.respond_to?(:job_data)
          job.payload_object.job_data.each do |key, value|
            extra[:"active_job.#{key}"] = value
          end
        end

        extra
      end
    end
  end
end

Delayed::Worker.plugins << Sentry::DelayedJob::Plugin

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
sentry-delayed_job-4.2.0	lib/sentry/delayed_job/plugin.rb