From b48050d0ef4c17038457e1abc7a14dbde997b587 Mon Sep 17 00:00:00 2001 From: Mike Perham Date: Tue, 20 May 2014 09:45:37 -0700 Subject: cleanup --- lib/active_job/queue_adapters/sucker_punch_adapter.rb | 10 +++------- 1 file changed, 3 insertions(+), 7 deletions(-) (limited to 'lib/active_job') diff --git a/lib/active_job/queue_adapters/sucker_punch_adapter.rb b/lib/active_job/queue_adapters/sucker_punch_adapter.rb index 79043b06e0..7bddf5ce8a 100644 --- a/lib/active_job/queue_adapters/sucker_punch_adapter.rb +++ b/lib/active_job/queue_adapters/sucker_punch_adapter.rb @@ -9,12 +9,7 @@ module ActiveJob end def queue_at(job, timestamp, *args) - delay = Time.now.to_f - timestamp - if delay > 0 - JobWrapper.new.async.later(delay, job, *args) - else - JobWrapper.new.async.perform(job, *args) - end + JobWrapper.new.async.later(timestamp, job, *args) end end @@ -26,7 +21,8 @@ module ActiveJob end def later(sec, job_name, *args) - after(sec) { perform(job_name, *args) } + delay = Time.now.to_f - sec + after(delay > 0 ? delay : 0) { perform(job_name, *args) } end end end -- cgit v1.2.3