Contents

# frozen_string_literal: true

module ActiveJob
  module Instrumentation # :nodoc:
    extend ActiveSupport::Concern

    included do
      around_enqueue do |_, block|
        scheduled_at ? instrument(:enqueue_at, &block) : instrument(:enqueue, &block)
      end
    end

    def perform_now
      instrument(:perform) { super }
    end

    private
      def _perform_job
        instrument(:perform_start)
        super
      end

      def instrument(operation, payload = {}, &block)
        enhanced_block = ->(event_payload) do
          value = block.call if block

          if defined?(@_halted_callback_hook_called) && @_halted_callback_hook_called
            event_payload[:aborted] = true
            @_halted_callback_hook_called = nil
          end

          value
        end

        ActiveSupport::Notifications.instrument \
          "#{operation}.active_job", payload.merge(adapter: queue_adapter, job: self), &enhanced_block
      end

      def halted_callback_hook(*)
        super
        @_halted_callback_hook_called = true
      end
  end
end

Version data entries

37 entries across 35 versions & 4 rubygems

Version	Path
activejob-7.0.4.2	lib/active_job/instrumentation.rb
activejob-7.0.4.1	lib/active_job/instrumentation.rb
activejob-7.0.4	lib/active_job/instrumentation.rb
activejob-7.0.3.1	lib/active_job/instrumentation.rb
activejob-7.0.3	lib/active_job/instrumentation.rb
activejob-7.0.2.4	lib/active_job/instrumentation.rb
activejob-7.0.2.3	lib/active_job/instrumentation.rb
activejob-7.0.2.2	lib/active_job/instrumentation.rb
activejob-7.0.2.1	lib/active_job/instrumentation.rb
activejob-7.0.2	lib/active_job/instrumentation.rb
activejob-7.0.1	lib/active_job/instrumentation.rb
activejob-7.0.0	lib/active_job/instrumentation.rb
activejob-7.0.0.rc3	lib/active_job/instrumentation.rb
activejob-7.0.0.rc2	lib/active_job/instrumentation.rb
activejob-7.0.0.rc1	lib/active_job/instrumentation.rb
activejob-7.0.0.alpha2	lib/active_job/instrumentation.rb
activejob-7.0.0.alpha1	lib/active_job/instrumentation.rb