diff options
| author | Larry Lv <larrylv1990@gmail.com> | 2014-05-21 12:48:23 +0800 |
|---|---|---|
| committer | Larry Lv <larrylv1990@gmail.com> | 2014-05-21 13:35:05 +0800 |
| commit | ce5a88d786c1d4665046aaec5bc1c9826b68aaa4 (patch) | |
| tree | a1fd88cb4cddd261afd3686c68a9bce49c608f6e /lib/active_job | |
| parent | d2245cb14f4e5b8b09de6f57b4f8c908bdc4d447 (diff) | |
| download | rails-ce5a88d786c1d4665046aaec5bc1c9826b68aaa4.tar.gz rails-ce5a88d786c1d4665046aaec5bc1c9826b68aaa4.tar.bz2 rails-ce5a88d786c1d4665046aaec5bc1c9826b68aaa4.zip | |
Ensure we are logging the serialized args.
Diffstat (limited to 'lib/active_job')
| -rw-r--r-- | lib/active_job/enqueuing.rb | 7 |
1 files changed, 4 insertions, 3 deletions
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 |