fix: airdrops in series (#1245)

decentraland · Sep 11, 2023 · 954d57c · 954d57c
1 parent b03a322
commit 954d57c
Showing 1 changed file with 8 additions and 5 deletions.
diff --git a/src/services/BadgesService.ts b/src/services/BadgesService.ts
@@ -117,11 +117,14 @@ export class BadgesService {
       landOwnerAddresses
     )
 
-    const outcomes = await Promise.all(
-      splitArray([...eligibleUsers, ...usersWithBadgesToReinstate], 20).map((addresses) =>
-        BadgesService.giveBadgeToUsers(LAND_OWNER_BADGE_SPEC_CID, addresses)
-      )
-    )
+    const outcomes: AirdropOutcome[] = []
+    const batches = splitArray([...eligibleUsers, ...usersWithBadgesToReinstate], 50)
+
+    for (const batch of batches) {
+      const outcome = await BadgesService.giveBadgeToUsers(LAND_OWNER_BADGE_SPEC_CID, batch)
+      outcomes.push(outcome)
+    }
+
     const failedOutcomes = outcomes.filter(
       ({ status, error }) =>
         status === AirdropJobStatus.FAILED &&