From 0a96662926c2c6f8b0e27eb4ad937fa0ef6d519e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Pascal=20Honor=C3=A9?= Date: Mon, 9 Sep 2024 14:52:38 +0100 Subject: [PATCH] notification batch size 1 --- .../pricemigrationengine/handlers/NotificationHandler.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/lambda/src/main/scala/pricemigrationengine/handlers/NotificationHandler.scala b/lambda/src/main/scala/pricemigrationengine/handlers/NotificationHandler.scala index 359df08d..f457b9d1 100644 --- a/lambda/src/main/scala/pricemigrationengine/handlers/NotificationHandler.scala +++ b/lambda/src/main/scala/pricemigrationengine/handlers/NotificationHandler.scala @@ -53,7 +53,7 @@ object NotificationHandler extends CohortHandler { today <- Clock.currentDateTime.map(_.toLocalDate) count <- CohortTable .fetch(SalesforcePriceRiceCreationComplete, Some(today.plusDays(maxLeadTime(cohortSpec)))) - .take(batchSize) + .take(1) .mapZIO(item => MigrationType(cohortSpec) match { case SupporterPlus2024 => {