Try to run recursiveDelete in parallel

Sunny-Tech · Apr 2, 2024 · aba1569 · aba1569
1 parent b4972fd
commit aba1569
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 4 deletions.
diff --git a/scripts/openplanner/getSpeakersSessionsSchedule.ts b/scripts/openplanner/getSpeakersSessionsSchedule.ts
@@ -146,7 +146,7 @@ export const getSpeakersSessionsSchedule = async (payload: {
       return 1
     }
     if (bDate && isNaN(bDate.getTime()) ) {
-      console.warn("Invalid date", b.id, a.title)
+      console.warn("Invalid date", b.id, b.title)
       return -1
     }
 

diff --git a/scripts/openplanner/runInParallel.ts b/scripts/openplanner/runInParallel.ts
@@ -14,9 +14,6 @@ export const runInParallel = async <T, R>(
       while (queue.length > 0) {
         const dataIndex = dataList.length - queue.length;
         const dataEl = queue.shift();
-
-        console.log(`Running ${index} for ${dataIndex}`);
-
         try {
           results[dataIndex] = await runFunction(dataEl);
         } catch (error) {
@@ -33,6 +30,14 @@ export const runInParallel = async <T, R>(
     };
 
     const parallelRequests = Math.min(numberOfParallelRequest, dataList.length);
+    console.log(`Running ${parallelRequests} parallel requests`);
+
+    if(parallelRequests === 0) {
+      resolve([]);
+      console.log('No parallel requests to run');
+      return;
+    }
+
     for (let i = 0; i < parallelRequests; i++) {
       processNext(i).catch(reject);
     }