Don't deserialize parameters in individual adapters.

It's not their responsibility and this makes logging (and rescuing from errors, eventually!) a lot easier.

1 files changed, 14 insertions, 0 deletions

diff --git a/lib/active_job/performing.rb b/lib/active_job/performing.rb
new file mode 100644
index 0000000000..6c304a4bed
--- /dev/null
+++ b/lib/active_job/performing.rb
@@ -0,0 +1,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