tech(pjs): add pjs migration cron

This commit is contained in:
simon lehericey 2023-07-12 11:43:15 +02:00 committed by LeSim
parent 3e30834644
commit ee471614eb

View file

@ -0,0 +1,26 @@
class Cron::PjsMigrationCronJob < Cron::CronJob
self.schedule_expression = "every 15 minutes"
def perform(*args)
# avoid reschedule enqueued jobs
# but ignore fail jobs
return if migration_jobs.count > 100
blobs = ActiveStorage::Blob
.where.not("key LIKE '%/%'")
.limit(200_000)
blobs.in_batches { |batch| batch.ids.each { |id| PjsMigrationJob.perform_later(id) } }
end
def self.schedulable?
ENV.fetch("MIGRATE_PJS", "enabled") == "enabled"
end
private
def migration_jobs
Delayed::Job
.where(queue: 'pj_migration_jobs')
end
end