diff options
| author | Mike Perham <mperham@gmail.com> | 2014-05-20 08:36:24 -0700 |
|---|---|---|
| committer | Mike Perham <mperham@gmail.com> | 2014-05-20 08:36:24 -0700 |
| commit | 1d3ba6881e03bc3096be2c68e3d28f88e3136f05 (patch) | |
| tree | cdfb28b20884ff763b3daa8c9c5df0a6422b3a20 /lib/active_job/queue_adapters/sidekiq_adapter.rb | |
| parent | b49d3f105f765a2c6c440fad5303a2809942422a (diff) | |
| download | rails-1d3ba6881e03bc3096be2c68e3d28f88e3136f05.tar.gz rails-1d3ba6881e03bc3096be2c68e3d28f88e3136f05.tar.bz2 rails-1d3ba6881e03bc3096be2c68e3d28f88e3136f05.zip | |
Move past time check out of adapters
Diffstat (limited to 'lib/active_job/queue_adapters/sidekiq_adapter.rb')
| -rw-r--r-- | lib/active_job/queue_adapters/sidekiq_adapter.rb | 2 |
1 files changed, 0 insertions, 2 deletions
diff --git a/lib/active_job/queue_adapters/sidekiq_adapter.rb b/lib/active_job/queue_adapters/sidekiq_adapter.rb index 41f58f554a..c6faf9d054 100644 --- a/lib/active_job/queue_adapters/sidekiq_adapter.rb +++ b/lib/active_job/queue_adapters/sidekiq_adapter.rb @@ -10,8 +10,6 @@ module ActiveJob def queue_at(job, timestamp, *args) job = { class: JobWrapper, queue: job.queue_name, args: [ job, *args ], at: timestamp } - # Optimization to enqueue something now that is scheduled to go out now or in the past - job.delete(:at) if timestamp <= Time.now.to_f JobWrapper.client_push(job) end end |