fix: postgres max call

SocialGouv · Jul 24, 2023 · c1ef85f · c1ef85f
1 parent 7e030e8
commit c1ef85f
Showing 1 changed file with 23 additions and 21 deletions.
diff --git a/targets/ingester/src/articles/update-kali-articles.ts b/targets/ingester/src/articles/update-kali-articles.ts
@@ -11,26 +11,28 @@ export const updateKaliArticles = async (): Promise<void> => {
   const { agreements } = await loadAgreements();
 
   let i = 0;
-  await Promise.all(
-    await pMap(
-      agreements,
-      async ({ idcc, kali_id }) => {
-        console.log(
-          `updateKaliData: ${++i}/${
-            agreements.length
-          } Updating agreement for IDCC ${idcc}`
-        );
-        const articles = await loadAgreementArticles(
-          kali_id,
-          idcc,
-          loadAgreement,
-          loadArticles
-        );
-        await updateAgreementArticles(idcc, articles);
-      },
-      {
-        concurrency: 10,
-      }
-    )
+  const promises = await pMap(
+    agreements,
+    async ({ idcc, kali_id }) => {
+      console.log(
+        `updateKaliData: ${++i}/${
+          agreements.length
+        } Updating agreement for IDCC ${idcc}`
+      );
+      const articles = await loadAgreementArticles(
+        kali_id,
+        idcc,
+        loadAgreement,
+        loadArticles
+      );
+      await updateAgreementArticles(idcc, articles);
+    },
+    {
+      concurrency: 10,
+    }
   );
+  await promises.reduce(async (previousPromise, process) => {
+    await previousPromise;
+    return await process;
+  }, Promise.resolve());
 };