diff options
Diffstat (limited to 'lib/active_job/queue_adapters/sucker_punch_adapter.rb')
| -rw-r--r-- | lib/active_job/queue_adapters/sucker_punch_adapter.rb | 8 |
1 files changed, 1 insertions, 7 deletions
diff --git a/lib/active_job/queue_adapters/sucker_punch_adapter.rb b/lib/active_job/queue_adapters/sucker_punch_adapter.rb index e483c0844b..8125499695 100644 --- a/lib/active_job/queue_adapters/sucker_punch_adapter.rb +++ b/lib/active_job/queue_adapters/sucker_punch_adapter.rb @@ -9,13 +9,7 @@ module ActiveJob end def queue_at(job, timestamp, *args) - secs = Time.now.to_f - timestamp - if secs < 1 - # Optimization to enqueue something now that is scheduled to go out now or in the past - JobWrapper.new.async.perform(job, *args) - else - JobWrapper.new.async.later(secs, job, *args) - end + JobWrapper.new.async.later(secs, job, *args) end end |