lib/rocket_job/jobs/housekeeping_job.rb in rocketjob-3.4.3 vs lib/rocket_job/jobs/housekeeping_job.rb in rocketjob-3.5.0

- old
+ new

@@ -52,14 +52,15 @@ # Requeue jobs where the worker is in the zombie state and its server has gone away RocketJob::ActiveWorker.requeue_zombies end RocketJob::Job.aborted.where(completed_at: {'$lte' => aborted_retention.seconds.ago}).destroy_all if aborted_retention - RocketJob::Job.completed.where(completed_at: {'$lte' => completed_retention.seconds.ago}).destroy_all if completed_retention + if completed_retention + RocketJob::Job.completed.where(completed_at: {'$lte' => completed_retention.seconds.ago}).destroy_all + end RocketJob::Job.failed.where(completed_at: {'$lte' => failed_retention.seconds.ago}).destroy_all if failed_retention RocketJob::Job.paused.where(completed_at: {'$lte' => paused_retention.seconds.ago}).destroy_all if paused_retention RocketJob::Job.queued.where(created_at: {'$lte' => queued_retention.seconds.ago}).destroy_all if queued_retention end - end end end