From dbdb5103537cda1ec83900f93cfe4122da45a484 Mon Sep 17 00:00:00 2001
From: Tore Langedal Endestad <tore.langedal.endestad@nav.no>
Date: Thu, 19 Dec 2024 13:35:10 +0100
Subject: [PATCH] =?UTF-8?q?K=C3=B8Id=20og=20antall=20til=20opentelemetry?=
 =?UTF-8?q?=20for=20k=C3=B8er=20i=20refresh-jobben?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../los/eventhandler/RefreshK9v3Tjeneste.kt   | 19 +++++++++++--------
 1 file changed, 11 insertions(+), 8 deletions(-)

diff --git a/src/main/kotlin/no/nav/k9/los/eventhandler/RefreshK9v3Tjeneste.kt b/src/main/kotlin/no/nav/k9/los/eventhandler/RefreshK9v3Tjeneste.kt
index 976ed4f31..d70b339fc 100644
--- a/src/main/kotlin/no/nav/k9/los/eventhandler/RefreshK9v3Tjeneste.kt
+++ b/src/main/kotlin/no/nav/k9/los/eventhandler/RefreshK9v3Tjeneste.kt
@@ -16,6 +16,7 @@ import no.nav.k9.los.nyoppgavestyring.mottak.oppgave.AktivOppgaveRepository
 import no.nav.k9.los.nyoppgavestyring.query.Avgrensning
 import no.nav.k9.los.nyoppgavestyring.query.OppgaveQueryService
 import no.nav.k9.los.nyoppgavestyring.query.QueryRequest
+import no.nav.k9.los.utils.OpentelemetrySpanUtil
 import org.slf4j.LoggerFactory
 import java.util.*
 
@@ -109,15 +110,17 @@ class RefreshK9v3Tjeneste(
             val førsteOppgaveIder = mutableSetOf<AktivOppgaveId>()
             for (kø in køer) {
                 DetaljerMetrikker.time("RefreshK9V3", "refreshForKøer", "hentFørsteOppgaverIterativt") {
-                    val førsteOppgaverIKøen = oppgaveQueryService.queryForOppgaveId(
-                        tx,
-                        QueryRequest(
-                            kø.oppgaveQuery,
-                            fjernReserverte = true,
-                            Avgrensning.maxAntall(antall = antallPrKø.toLong())
+                    OpentelemetrySpanUtil.span("hentFørsteUreserverteFraKø", mapOf("køId" to kø.id.toString(), "antall" to antallPrKø.toString())) {
+                        val førsteOppgaverIKøen = oppgaveQueryService.queryForOppgaveId(
+                            tx,
+                            QueryRequest(
+                                kø.oppgaveQuery,
+                                fjernReserverte = true,
+                                Avgrensning.maxAntall(antall = antallPrKø.toLong())
+                            )
                         )
-                    )
-                    førsteOppgaveIder.addAll(førsteOppgaverIKøen)
+                        førsteOppgaveIder.addAll(førsteOppgaverIKøen)
+                    }
                 }
             }
             DetaljerMetrikker.time("RefreshK9V3", "refreshForKøer", "parsaker") {