diff --git a/activejob/lib/active_job/enqueuing.rb b/activejob/lib/active_job/enqueuing.rb index e3ac11ba97..c00aab40da 100644 --- a/activejob/lib/active_job/enqueuing.rb +++ b/activejob/lib/active_job/enqueuing.rb @@ -57,7 +57,7 @@ module ActiveJob end def retry_now - self.class.enqueue *arguments + self.class.enqueue(*arguments) end def retry_in(interval) diff --git a/activejob/lib/active_job/execution.rb b/activejob/lib/active_job/execution.rb index 78ada3d908..181d049616 100644 --- a/activejob/lib/active_job/execution.rb +++ b/activejob/lib/active_job/execution.rb @@ -14,14 +14,14 @@ module ActiveJob self.arguments = Arguments.deserialize(serialized_args) run_callbacks :perform do - perform *arguments + perform(*arguments) end rescue => exception rescue_with_handler(exception) || raise(exception) end def perform(*) - raise NotImplementedError + fail NotImplementedError end end end