mirror of
https://github.com/rails/rails.git
synced 2022-11-09 12:12:34 -05:00
Ensure we are logging the serialized args.
This commit is contained in:
parent
d2245cb14f
commit
ce5a88d786
1 changed files with 4 additions and 3 deletions
|
@ -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
|
||||
|
|
Loading…
Reference in a new issue