diff --git a/packages/api/src/jobs/ai/create_digest.ts b/packages/api/src/jobs/ai/create_digest.ts index 98ee0488f..81c6512f8 100644 --- a/packages/api/src/jobs/ai/create_digest.ts +++ b/packages/api/src/jobs/ai/create_digest.ts @@ -598,8 +598,10 @@ const sendNotifications = async ( channels: Channel[], digest: Digest ) => { + const deduplicateChannels = [...new Set(channels)] + await Promise.all( - channels.map(async (channel) => { + deduplicateChannels.map(async (channel) => { switch (channel) { case 'push': return sendPushNotification(user.id, digest)