demarches-normaliennes/app/jobs/tmp_dossiers_migrate_revisions_job.rb

class TmpDossiersMigrateRevisionsJob < ApplicationJob
  def perform(except)
    dossiers = Dossier.with_discarded.where(revision_id: nil)

    dossiers.where
      .not(id: except)
      .includes(procedure: [:draft_revision, :published_revision])
      .limit(2000)
      .find_each do |dossier|
        if dossier.procedure.present?
          dossier.update_column(:revision_id, dossier.procedure.active_revision_id)
        else
          except << dossier.id
        end
      end

    if dossiers.where.not(id: except).exists?
      TmpDossiersMigrateRevisionsJob.perform_later(except)
    end
  end
end