c95108d37b
Fix cases where not all daily maintenance tasks run because some earlier task raised an exception.
44 lines
1.2 KiB
Ruby
44 lines
1.2 KiB
Ruby
module DanbooruMaintenance
|
|
module_function
|
|
|
|
def hourly
|
|
end
|
|
|
|
def daily
|
|
safely { PostPruner.new.prune! }
|
|
safely { Upload.prune! }
|
|
safely { Delayed::Job.where('created_at < ?', 45.days.ago).delete_all }
|
|
safely { PostDisapproval.prune! }
|
|
safely { ForumSubscription.process_all! }
|
|
safely { PostDisapproval.dmail_messages! }
|
|
safely { regenerate_post_counts! }
|
|
safely { SuperVoter.init! }
|
|
safely { TokenBucket.prune! }
|
|
safely { TagChangeRequestPruner.warn_all }
|
|
safely { TagChangeRequestPruner.reject_all }
|
|
safely { Ban.prune! }
|
|
safely { CuratedPoolUpdater.update_pool! }
|
|
safely { ActiveRecord::Base.connection.execute("vacuum analyze") unless Rails.env.test? }
|
|
end
|
|
|
|
def weekly
|
|
safely { UserPasswordResetNonce.prune! }
|
|
safely { ApproverPruner.prune! }
|
|
safely { TagRelationshipRetirementService.find_and_retire! }
|
|
end
|
|
|
|
def regenerate_post_counts!
|
|
updated_tags = Tag.regenerate_post_counts!
|
|
updated_tags.each do |tag|
|
|
DanbooruLogger.info("Updated tag count", tag.attributes)
|
|
end
|
|
end
|
|
|
|
def safely(&block)
|
|
ActiveRecord::Base.connection.execute("set statement_timeout = 0")
|
|
yield
|
|
rescue StandardError => exception
|
|
DanbooruLogger.log(exception)
|
|
end
|
|
end
|