fix: try batch iterator generator

hirosystems · Nov 12, 2023 · e2ed039 · e2ed039
1 parent 2037647
commit e2ed039
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/pg/pg-store.ts b/src/pg/pg-store.ts
@@ -3,6 +3,7 @@ import {
   PgConnectionVars,
   PgSqlClient,
   PgSqlQuery,
+  batchIterate,
   connectPostgres,
   logger,
   runMigrations,
@@ -255,7 +256,7 @@ export class PgStore extends BasePgStore {
         });
         // Divide insertion array into chunks of 3000 in order to avoid the postgres limit of 65534
         // query params.
-        for (const writeChunk of chunkArray(writes, 3000))
+        for (const writeChunk of batchIterate(writes, 3000))
           await this.insertInscriptions(writeChunk);
         updatedBlockHeightMin = Math.min(updatedBlockHeightMin, event.block_identifier.index);
         if (ENV.BRC20_BLOCK_SCAN_ENABLED)