From ce5a88d786c1d4665046aaec5bc1c9826b68aaa4 Mon Sep 17 00:00:00 2001 From: Larry Lv Date: Wed, 21 May 2014 12:48:23 +0800 Subject: Ensure we are logging the serialized args. --- lib/active_job/enqueuing.rb | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) (limited to 'lib/active_job') diff --git a/lib/active_job/enqueuing.rb b/lib/active_job/enqueuing.rb index 80b10cdbcb..7f2aef871e 100644 --- a/lib/active_job/enqueuing.rb +++ b/lib/active_job/enqueuing.rb @@ -30,9 +30,10 @@ module ActiveJob # # Returns truthy if a job was scheduled. def enqueue_at(timestamp, *args) - timestamp = timestamp.to_f - ActiveSupport::Notifications.instrument "enqueue_at.active_job", adapter: queue_adapter, timestamp: timestamp, job: self, args: args - queue_adapter.queue_at self, timestamp, *Parameters.serialize(args) + timestamp = timestamp.to_f + serialized_args = Parameters.serialize(args) + ActiveSupport::Notifications.instrument "enqueue_at.active_job", adapter: queue_adapter, timestamp: timestamp, job: self, args: serialized_args + queue_adapter.queue_at self, timestamp, *serialized_args end end end -- cgit v1.2.3