From 243d74eb30464dc95cb07c0bd14cc086f9cd7022 Mon Sep 17 00:00:00 2001 From: Cristian Bica Date: Sat, 31 May 2014 02:19:30 +0300 Subject: Persist job_id --- lib/active_job/execution.rb | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) (limited to 'lib/active_job/execution.rb') 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 -- cgit v1.2.3