diff --git a/src/rewards/index.js b/src/rewards/index.js
index 763a69afa8..c693b550fc 100644
--- a/src/rewards/index.js
+++ b/src/rewards/index.js
@@ -69,6 +69,10 @@ function getIDsByCondition(condition, callback) {
 
 function filterCompletedRewards(uid, rewards, callback) {
 	db.getSortedSetRangeByScoreWithScores('uid:' + uid + ':rewards', 0, -1, 1, Infinity, function(err, data) {
+		if (err) {
+			return callback(err);
+		}
+
 		var userRewards = {};
 
 		data.forEach(function(obj) {