module ActiveJob::Instrumentation

def instrument(operation, payload = {}, &block)
  payload[:job] = self
  payload[:adapter] = queue_adapter
  ActiveSupport::Notifications.instrument("#{operation}.active_job", payload) do
    value = block.call if block
    payload[:aborted] = @_halted_callback_hook_called if defined?(@_halted_callback_hook_called)
    @_halted_callback_hook_called = nil
    value
  end
end