diff options
Diffstat (limited to 'lib/active_job/performing.rb')
-rw-r--r-- | lib/active_job/performing.rb | 14 |
1 files changed, 6 insertions, 8 deletions
diff --git a/lib/active_job/performing.rb b/lib/active_job/performing.rb index eca311578d..126193995c 100644 --- a/lib/active_job/performing.rb +++ b/lib/active_job/performing.rb @@ -2,18 +2,16 @@ require 'active_job/parameters' module ActiveJob module Performing - def perform_with_deserialization(*serialized_args) - instrument_performing serialized_args - perform *Parameters.deserialize(serialized_args) + def perform_with_hooks(*serialized_args) + self.arguments = Parameters.deserialize(serialized_args) + + run_callbacks :perform do + perform *arguments + end end def perform(*) raise NotImplementedError end - - private - def instrument_performing(args) - ActiveSupport::Notifications.instrument "perform.active_job", adapter: self.class.queue_adapter, job: self.class, args: args - end end end |