lib/rocket_job/plugins/job/model.rb in rocketjob-3.0.0.beta vs lib/rocket_job/plugins/job/model.rb in rocketjob-3.0.0.beta2
- old
+ new
@@ -148,9 +148,10 @@
# Scope for queued jobs that can run now
# I.e. Queued jobs excluding scheduled jobs
def queued_now
queued.or(
{:run_at.exists => false},
+ {:run_at => nil},
{:run_at.lte => Time.now}
)
end
# DEPRECATED