Merge branch '1.0.x' into PIN-4294

pagopa · Dec 6, 2023 · d588907 · d588907
2 parents a8ada9a + c62e614
commit d588907
Showing 1 changed file with 19 additions and 6 deletions.
diff --git a/...rator/src/main/scala/it/pagopa/interop/metricsreportgenerator/util/ReadModelQueries.scala b/...rator/src/main/scala/it/pagopa/interop/metricsreportgenerator/util/ReadModelQueries.scala
@@ -76,7 +76,13 @@ object ReadModelQueries {
       secondProjection
     )
 
-    readModelService.aggregate[Agreement](config.agreements, aggregation, offset, limit)
+    readModelService.aggregate[Agreement](
+      collectionName = config.agreements,
+      pipeline = aggregation,
+      offset = offset,
+      limit = limit,
+      allowDiskUse = true
+    )
   }
 
   private def getPurposes(
@@ -94,7 +100,13 @@ object ReadModelQueries {
         exclude("_id")
       )
     )
-    readModelService.aggregate[Purpose](collections.purposes, Seq(projection), offset, limit)
+    readModelService.aggregate[Purpose](
+      collectionName = collections.purposes,
+      pipeline = Seq(projection),
+      offset = offset,
+      limit = limit,
+      allowDiskUse = true
+    )
   }
 
   private def getDescriptors(
@@ -136,10 +148,11 @@ object ReadModelQueries {
     )
 
     readModelService.aggregateRaw[Descriptor](
-      collections.eservices,
-      Seq(projection1, unwindStep, zipProducer, unwindStep2, projection2),
-      offset,
-      limit
+      collectionName = collections.eservices,
+      pipeline = Seq(projection1, unwindStep, zipProducer, unwindStep2, projection2),
+      offset = offset,
+      limit = limit,
+      allowDiskUse = true
     )
   }