diff --git a/services/document-updater/app/coffee/RedisManager.coffee b/services/document-updater/app/coffee/RedisManager.coffee
index 6a920b42c4..69d917815e 100644
--- a/services/document-updater/app/coffee/RedisManager.coffee
+++ b/services/document-updater/app/coffee/RedisManager.coffee
@@ -81,6 +81,7 @@ module.exports = RedisManager =
 		multi.lrange keys.pendingUpdates(doc_id:doc_id), 0 , -1
 		multi.del keys.pendingUpdates(doc_id:doc_id)
 		multi.exec (error, replys) ->
+			return callback(error) if error?
 			jsonUpdates = replys[0]
 			updates = []
 			for jsonUpdate in jsonUpdates