From a90383ab1d2e27de7b0998b85d211e07c6dc04e5 Mon Sep 17 00:00:00 2001 From: Ralf Steppacher Date: Thu, 17 Oct 2024 13:39:51 +0200 Subject: [PATCH] #37649 only log which directories are being polled for documents to upload once at startup; per-execution polling logs are now on level DEBUG --- .../cdr/clientvm/scheduling/DocumentUploadSchedulers.kt | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/src/main/kotlin/com/swisscom/health/des/cdr/clientvm/scheduling/DocumentUploadSchedulers.kt b/src/main/kotlin/com/swisscom/health/des/cdr/clientvm/scheduling/DocumentUploadSchedulers.kt index af357b3..a602927 100644 --- a/src/main/kotlin/com/swisscom/health/des/cdr/clientvm/scheduling/DocumentUploadSchedulers.kt +++ b/src/main/kotlin/com/swisscom/health/des/cdr/clientvm/scheduling/DocumentUploadSchedulers.kt @@ -181,6 +181,11 @@ class PollingUploadScheduler( @Scheduled(initialDelay = 0L, timeUnit = TimeUnit.MILLISECONDS) suspend fun launchFilePoller() { + config.scheduleDelay.toString().substring(2).replace("""(\d[HMS])(?!$)""".toRegex(), "$1 ").lowercase().let{ humanReadableDelay -> + config.customer.forEach { + logger.info { "Polling source folder for files every '$humanReadableDelay': '${it.sourceFolder}'" } + } + } withContext(Dispatchers.IO) { launch { uploadFiles(pollForNewFilesToUpload()) @@ -195,7 +200,7 @@ class PollingUploadScheduler( .asSequence() .map { startSpan(tracer, "poll directory ${it.sourceFolder}") { - logger.info { "Polling source folder for files: ${it.sourceFolder}" } + logger.debug { "Polling source folder for files: ${it.sourceFolder}" } it.sourceFolder } }