Hendelseprosessor: Begrenser antall states som gjennomgåes for sletti…

…ng til 10k for å hindre timeout errors, senker intervallet for sletting til 2 timer
navikt · Dec 23, 2024 · b54e65c · b54e65c
1 parent 0bd5081
commit b54e65c
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/...o/nav/paw/arbeidssokerregisteret/app/funksjoner/kafkastreamsprocessors/TilstandsLaster.kt b/...o/nav/paw/arbeidssokerregisteret/app/funksjoner/kafkastreamsprocessors/TilstandsLaster.kt
@@ -36,7 +36,7 @@ class TilstandsLaster(
         tilstandsopprydding(
             requireNotNull(context) { "Context er ikke initialisert" },
             requireNotNull(tilstandsDb){ "TilstandsDb er ikke initialisert" },
-            Duration.ofDays(1),
+            Duration.ofHours(2),
             keepGoing
         )
     }

diff --git a/...v/paw/arbeidssokerregisteret/app/funksjoner/kafkastreamsprocessors/Tilstandsopprydding.kt b/...v/paw/arbeidssokerregisteret/app/funksjoner/kafkastreamsprocessors/Tilstandsopprydding.kt
@@ -22,6 +22,7 @@ fun tilstandsopprydding(
     stateStore.all().use { tilstander ->
         tilstander.asSequence().takeWhile { keepGoing.get() }
             .filter { it.value.skalSlettes() }
+            .take(10000)
             .onEach { tilstand ->
                 try {
                     stateStore.delete(tilstand.key)