From 3f0bb9811bc1e8b5f979d469f4a89e32d70bcb8c Mon Sep 17 00:00:00 2001 From: yemregurses Date: Thu, 28 Nov 2024 09:45:06 +0300 Subject: [PATCH] :loud_sound: write total number of chunks to logs during mapping job execution --- .../io/tofhir/engine/mapping/job/FhirMappingJobManager.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tofhir-engine/src/main/scala/io/tofhir/engine/mapping/job/FhirMappingJobManager.scala b/tofhir-engine/src/main/scala/io/tofhir/engine/mapping/job/FhirMappingJobManager.scala index 91cffd9c..e3e718ba 100644 --- a/tofhir-engine/src/main/scala/io/tofhir/engine/mapping/job/FhirMappingJobManager.scala +++ b/tofhir-engine/src/main/scala/io/tofhir/engine/mapping/job/FhirMappingJobManager.scala @@ -334,7 +334,7 @@ class FhirMappingJobManager( case (fj, (df, i)) => fj.flatMap(_ => executeTask(mappingJobExecution.jobId, mappingTask.name, fhirMapping, df, mds, terminologyServiceSettings, identityServiceSettings, Some(mappingJobExecution.id), projectId = Some(mappingJobExecution.projectId)) .map(dataset => SinkHandler.writeMappingResult(spark, mappingJobExecution, Some(mappingTask.name), dataset, fhirWriter)) - .map(_ => logger.debug(s"Chunk ${i + 1} is completed for mapping ${mappingTask.name} within MappingJob: ${mappingJobExecution.jobId}...")) + .map(_ => logger.debug(s"Chunk ${i + 1} / $numOfChunks is completed for mapping ${mappingTask.name} within MappingJob: ${mappingJobExecution.jobId}...")) ) } }