Merge acf6cab into 7db5654

collectiveidea · Jun 28, 2017 · a896200 · a896200
2 parents 7db5654 + acf6cab
commit a896200
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/delayed/tasks.rb b/lib/delayed/tasks.rb
@@ -30,7 +30,7 @@
   task :check, [:max_age] => :environment do |_, args|
     args.with_defaults(:max_age => 300)
 
-    unprocessed_jobs = Delayed::Job.where('attempts = 0 AND created_at < ?', Time.now - args[:max_age].to_i).count
+    unprocessed_jobs = Delayed::Job.where('attempts = 0 AND run_at < ?', Time.now - args[:max_age].to_i).count
 
     if unprocessed_jobs > 0
       raise "#{unprocessed_jobs} jobs older than #{args[:max_age]} seconds have not been processed yet"