From 49cd622e450a060787ed3669871b2b72fb4eda71 Mon Sep 17 00:00:00 2001 From: Kilian Schuettler Date: Wed, 16 Aug 2023 10:28:47 +0200 Subject: [PATCH] DM-357: schedule reanalysis for every manualRedaction * silence that stupid automaticAnalysisJob spamming --- .../management/v1/processor/service/FileStatusService.java | 2 +- .../v1/processor/service/job/AutomaticAnalysisJob.java | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/service/FileStatusService.java b/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/service/FileStatusService.java index d4c97a921..012b76a4b 100644 --- a/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/service/FileStatusService.java +++ b/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/service/FileStatusService.java @@ -83,7 +83,7 @@ public class FileStatusService { var fileEntities = fileStatusPersistenceService.getAllRelevantStatusesForReanalysisScheduler(fileManagementServiceSettings.getMaxErrorRetries()); var convertedList = MagicConverter.convert(fileEntities, FileModel.class, new FileModelMapper()); - log.info("Initial list of files for scheduler contains: {} files.", fileEntities.size()); + log.debug("Initial list of files for scheduler contains: {} files.", fileEntities.size()); return reanalysisRequiredStatusService.enhanceFileStatusWithAnalysisRequirements(convertedList).stream().filter(FileModel::isAnalysisRequired).collect(Collectors.toList()); } diff --git a/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/service/job/AutomaticAnalysisJob.java b/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/service/job/AutomaticAnalysisJob.java index 2641a9b06..32a7e3313 100644 --- a/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/service/job/AutomaticAnalysisJob.java +++ b/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/service/job/AutomaticAnalysisJob.java @@ -53,7 +53,7 @@ public class AutomaticAnalysisJob implements Job { var redactionQueueInfo = amqpAdmin.getQueueInfo(MessagingConfiguration.REDACTION_QUEUE); if (redactionQueueInfo != null) { - log.info("[Tenant:{}] Checking queue status to see if background analysis can happen. Currently {} holds {} elements and has {} consumers", + log.debug("[Tenant:{}] Checking queue status to see if background analysis can happen. Currently {} holds {} elements and has {} consumers", tenant.getTenantId(), MessagingConfiguration.REDACTION_QUEUE, redactionQueueInfo.getMessageCount(), @@ -67,7 +67,7 @@ public class AutomaticAnalysisJob implements Job { allStatuses.sort(Comparator.comparing(FileModel::getLastUpdated)); var allStatusesIterator = allStatuses.iterator(); - log.info("[Tenant:{}] Files that require reanalysis: {}", TenantContext.getTenantId(), allStatuses.size()); + log.debug("[Tenant:{}] Files that require reanalysis: {}", TenantContext.getTenantId(), allStatuses.size()); var queuedFiles = 0;