aboutsummaryrefslogtreecommitdiffstats
path: root/lib/active_job/performing.rb
diff options
context:
space:
mode:
Diffstat (limited to 'lib/active_job/performing.rb')
-rw-r--r--lib/active_job/performing.rb14
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