From 8bf0a443db30aaaf315ecb36c72429e3f11926b8 Mon Sep 17 00:00:00 2001
From: Alex Gleason <alex@alexgleason.me>
Date: Tue, 15 Oct 2024 16:27:48 -0500
Subject: [PATCH] pipeline: Promise.all -> Promise.allSettled

---
 src/pipeline.ts | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)

diff --git a/src/pipeline.ts b/src/pipeline.ts
index 9125c505..b965f598 100644
--- a/src/pipeline.ts
+++ b/src/pipeline.ts
@@ -69,19 +69,18 @@ async function handleEvent(event: DittoEvent, signal: AbortSignal): Promise<void
     await storeEvent(purifyEvent(event), signal);
   } finally {
     // This needs to run in steps, and should not block the API from responding.
-    Promise.all([
+    Promise.allSettled([
       handleZaps(kysely, event),
       parseMetadata(event, signal),
       setLanguage(event),
       generateSetEvents(event),
     ])
       .then(() =>
-        Promise.all([
+        Promise.allSettled([
           streamOut(event),
           webPush(event),
         ])
-      )
-      .catch(console.warn);
+      );
   }
 }