class SetStepRowMetadata implements BaseUpgradeTaskTo_2_1_0_PE {

    @Override
    public void run() {

        final AtomicLong current = new AtomicLong(0);
        final long count = repository.list(PersistentPreparation.class).count();
        LOGGER.info("Starting a potentially long migration task, there are {} preparations to process", count);
        repository.list(PersistentPreparation.class).forEach(p -> setStepRowMetadata(p, current, count));
        LOGGER.info("Finished setting up row metadata in preparation steps");
    }

}