perf: parallel DAG size calculations

web3-storage · Aug 12, 2021 · 2f80af9 · 2f80af9
1 parent 2861e33
commit 2f80af9
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/packages/cron/src/jobs/pins.js b/packages/cron/src/jobs/pins.js
@@ -20,6 +20,7 @@ const FIND_PENDING_PINS = gql`
           peerId
         }
         status
+        created
       }
       after
     }
@@ -112,7 +113,7 @@ export async function updatePinStatuses ({ cluster, db, ipfs }) {
     }))
     log('✅ Done')
 
-    for (const pin of checkDagSizePins) {
+    await Promise.all(checkDagSizePins.map(async pin => {
       log(`⏳ ${pin.content.cid}: Querying DAG size...`)
       let dagSize
       try {
@@ -124,7 +125,7 @@ export async function updatePinStatuses ({ cluster, db, ipfs }) {
         log(`💥 ${pin.content.cid}@${pin.location.peerId}: Failed to update DAG size`)
         log(err)
       }
-    }
+    }))
 
     after = queryRes.findPinsByStatus.after
     if (!after) break