Lisää lokitusta hakemusten hakemiseen YTL-ajossa.

Opetushallitus · Apr 2, 2024 · e088b89 · e088b89
1 parent 2a97bd9
commit e088b89
Showing 1 changed file with 13 additions and 3 deletions.
diff --git a/src/main/scala/fi/vm/sade/hakurekisteri/integration/ytl/YtlIntegration.scala b/src/main/scala/fi/vm/sade/hakurekisteri/integration/ytl/YtlIntegration.scala
@@ -112,9 +112,19 @@ class YtlIntegration(
             .map(_.flatten)
         }
 
-        hakuOids.grouped(10).foldLeft(Future.successful(Set.empty[HetuPersonOid])) {
-          case (result, chunk) => result.flatMap(rs => fetchChunk(chunk).map(rs ++ _))
-        }
+        val hakuOidsChunkSize = 10
+        hakuOids.zipWithIndex
+          .grouped(hakuOidsChunkSize)
+          .foldLeft(Future.successful(Set.empty[HetuPersonOid])) {
+            case (result, chunkWithIndex) => {
+              val chunk = chunkWithIndex.map(_._1)
+              val firstIndex = chunkWithIndex.map(_._2).head
+              logger.info(
+                s"Fetching hakuOid chunk. First hakuOid is ${firstIndex}/${hakuOids.size} (Chunk size is ${hakuOidsChunkSize} and hakuOids are ${chunk})"
+              )
+              result.flatMap(rs => fetchChunk(chunk).map(rs ++ _))
+            }
+          }
       }
 
       logger.info(s"Fetching in chunks, activeKKHakuOids: ${activeKKHakuOids.get()}")