From 9938a139fe486bf3852192218940d9641db9470e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Bar=C4=B1=C5=9F=20Soner=20U=C5=9Fakl=C4=B1?= Date: Fri, 15 Jan 2021 14:42:19 -0500 Subject: [PATCH] fix: add missing await --- src/notifications.js | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/notifications.js b/src/notifications.js index 1befdc8c24..1b12d27e39 100644 --- a/src/notifications.js +++ b/src/notifications.js @@ -329,7 +329,7 @@ Notifications.prune = async function () { await batch.processSortedSet('users:joindate', async function (uids) { const unread = uids.map(uid => 'uid:' + uid + ':notifications:unread'); const read = uids.map(uid => 'uid:' + uid + ':notifications:read'); - db.sortedSetsRemoveRangeByScore(unread.concat(read), '-inf', cutoffTime); + await db.sortedSetsRemoveRangeByScore(unread.concat(read), '-inf', cutoffTime); }, { batch: 500, interval: 100 }); } catch (err) { if (err) {