Напиши реализацию метода реактивной цепочки project reactor если возникло исключение то продолжить выполнение с начала
Mono.just(context -> repository.findEntities(context, properties.getBatchSize()))
.repeat()
.takeWhile(CollectionUtils::isNotEmpty)
.flatMap(this::sendActionsAndGetResult)
.flatMap(tuple -> updateManualCorrectionAndDueDateLog(tuple, type))
.switchIfEmpty(Mono.just(Map.of(“PREPARED”, 0)))
.subscribeOn(SEND_SCHEDULER)
.subscribe();