Fixed Active Job Backburner adapter

alan · Aug 29, 2014 · 02b63a5 · 02b63a5
1 parent f8d9a51
commit 02b63a5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/activejob/lib/active_job/queue_adapters/backburner_adapter.rb b/activejob/lib/active_job/queue_adapters/backburner_adapter.rb
@@ -9,7 +9,7 @@ def enqueue(job, *args)
         end
 
         def enqueue_at(job, timestamp, *args)
-          delay = Time.current.to_f - timestamp
+          delay = timestamp - Time.current.to_f
           Backburner::Worker.enqueue JobWrapper, [ job.name, *args ], queue: job.queue_name, delay: delay
         end
       end