fix: add missing await

4 years ago · 9938a139fe
parent ceb1566834
commit 9938a139fe
1 changed files with 1 additions and 1 deletions
--- 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) {