chore(task): divides the import limits

ecomplus · Sep 6, 2024 · 16b144f · 16b144f
1 parent 506f1a3
commit 16b144f
Showing 1 changed file with 13 additions and 2 deletions.
diff --git a/functions/lib/tasks.js b/functions/lib/tasks.js
@@ -214,22 +214,33 @@ const handleWorker = async () => {
     const storeIds = []
     if (!notificationDocs.empty) {
       const docsToRun = []
+      const docsImgToRun = []
       notificationDocs.forEach(doc => {
-        if (docsToRun.length < 20) {
-          const data = doc.data()
+        const data = doc.data()
+        if (docsToRun.length < 30 && data.resource !== 'feed_import_image') {
           if (queueState && queueState.store_ids && !queueState.store_ids.includes(data.store_id)) {
             if (!storeIds.includes(data.store_id)) {
               storeIds.push(data.store_id)
             }
             docsToRun.push(run(doc, data))
           }
         }
+
+        if (docsImgToRun.length < 5 && data.resource === 'feed_import_image') {
+          if (queueState && queueState.store_ids && !queueState.store_ids.includes(data.store_id)) {
+            if (!storeIds.includes(data.store_id)) {
+              storeIds.push(data.store_id)
+            }
+            docsImgToRun.push(run(doc, data))
+          }
+        }
       })
       queueControllerRef.doc(queueController.id).set({
         running: true,
         store_ids: storeIds
       }, { merge: true })
       await Promise.allSettled(docsToRun)
+      await Promise.allSettled(docsImgToRun)
     }
 
     queueControllerSnap = await queueControllerRef.get()