diff options
Diffstat (limited to 'lib/active_job/enqueuing.rb')
| -rw-r--r-- | lib/active_job/enqueuing.rb | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/lib/active_job/enqueuing.rb b/lib/active_job/enqueuing.rb index bb681d1e32..43bce125b5 100644 --- a/lib/active_job/enqueuing.rb +++ b/lib/active_job/enqueuing.rb @@ -32,11 +32,12 @@ module ActiveJob # # Returns truthy if a job was scheduled. def enqueue_at(timestamp, *args) - ActiveSupport::Notifications.instrument "enqueue_at.active_job", adapter: queue_adapter, timestamp: timestamp, job: self, params: args - if Time.now.to_f > timestamp - queue.adapter.queue self, *Parameters.serialize(args) + ts = timestamp.to_f + ActiveSupport::Notifications.instrument "enqueue_at.active_job", adapter: queue_adapter, timestamp: ts, job: self, params: args + if Time.now.to_f > ts + queue_adapter.queue self, *Parameters.serialize(args) else - queue_adapter.queue_at self, timestamp.to_f, *Parameters.serialize(args) + queue_adapter.queue_at self, ts, *Parameters.serialize(args) end end end |