diff options
Diffstat (limited to 'lib/active_job/enqueuing.rb')
| -rw-r--r-- | lib/active_job/enqueuing.rb | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/lib/active_job/enqueuing.rb b/lib/active_job/enqueuing.rb index b2d142ee96..1e0dd58b59 100644 --- a/lib/active_job/enqueuing.rb +++ b/lib/active_job/enqueuing.rb @@ -32,7 +32,11 @@ module ActiveJob # # Returns truthy if a job was scheduled. def enqueue_at(timestamp, *args) - queue_adapter.queue_at self, timestamp.to_f, *Parameters.serialize(args) + if Time.now.to_f > timestamp + queue.adapter.queue self, *Parameters.serialize(args) + else + queue_adapter.queue_at self, timestamp.to_f, *Parameters.serialize(args) + end end end end |