lib/active_job/performing.rb


1
2
3
4
5
6
7
8
9
10
11
12
13
14

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