update notifiation batch size

guardian · Sep 9, 2024 · 6ea69d5 · 6ea69d5
1 parent eb09c77
commit 6ea69d5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lambda/src/main/scala/pricemigrationengine/handlers/NotificationHandler.scala b/lambda/src/main/scala/pricemigrationengine/handlers/NotificationHandler.scala
@@ -49,7 +49,7 @@ object NotificationHandler extends CohortHandler {
       today <- Clock.currentDateTime.map(_.toLocalDate)
       count <- CohortTable
         .fetch(SalesforcePriceRiceCreationComplete, Some(today.plusDays(maxLeadTime(cohortSpec))))
-        .take(1)
+        .take(batchSize)
         .mapZIO(item =>
           MigrationType(cohortSpec) match {
             case SupporterPlus2024 => {