diff options
| author | Cristian Bica <cristian.bica@gmail.com> | 2014-05-31 02:19:30 +0300 |
|---|---|---|
| committer | Cristian Bica <cristian.bica@gmail.com> | 2014-06-12 14:01:40 +0300 |
| commit | 243d74eb30464dc95cb07c0bd14cc086f9cd7022 (patch) | |
| tree | 34301629fe446bd394b5b0e32cf66f949afe0d53 /lib/active_job/execution.rb | |
| parent | 4ac8dc21440ecdea9c0452a0c12e8bcc487bc776 (diff) | |
| download | rails-243d74eb30464dc95cb07c0bd14cc086f9cd7022.tar.gz rails-243d74eb30464dc95cb07c0bd14cc086f9cd7022.tar.bz2 rails-243d74eb30464dc95cb07c0bd14cc086f9cd7022.zip | |
Persist job_id
Diffstat (limited to 'lib/active_job/execution.rb')
| -rw-r--r-- | lib/active_job/execution.rb | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/lib/active_job/execution.rb b/lib/active_job/execution.rb index d21fd32292..78ada3d908 100644 --- a/lib/active_job/execution.rb +++ b/lib/active_job/execution.rb @@ -4,12 +4,13 @@ require 'active_job/arguments' module ActiveJob module Execution extend ActiveSupport::Concern - + included do include ActiveSupport::Rescuable end - def execute(*serialized_args) + def execute(job_id, *serialized_args) + self.job_id = job_id self.arguments = Arguments.deserialize(serialized_args) run_callbacks :perform do |