path: root/lib/active_job/performing.rb

require 'active_job/parameters'

module ActiveJob
  module Performing
    def perform_with_deserialization(*serialized_args)
      ActiveSupport::Notifications.instrument "perform.active_job", adapter: self.class.queue_adapter, job: self.class, args: serialized_args
      perform *Parameters.deserialize(serialized_args)
    end

    def perform(*)
      raise NotImplementedError
    end
  end
end