From a8b14552c0069f22026e794412a87cd920174f42 Mon Sep 17 00:00:00 2001 From: Brian Gough Date: Tue, 19 Dec 2017 12:27:57 +0000 Subject: [PATCH] allow flush to succeed when doc is already deleted --- .../document-updater/app/coffee/ProjectManager.coffee | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/services/document-updater/app/coffee/ProjectManager.coffee b/services/document-updater/app/coffee/ProjectManager.coffee index fe7867319d..03b57acf53 100644 --- a/services/document-updater/app/coffee/ProjectManager.coffee +++ b/services/document-updater/app/coffee/ProjectManager.coffee @@ -20,10 +20,15 @@ module.exports = ProjectManager = do (doc_id) -> jobs.push (callback) -> DocumentManager.flushDocIfLoadedWithLock project_id, doc_id, (error) -> - if error? + if error? and error instanceof Errors.NotFoundError + logger.warn err: error, project_id: project_id, doc_id: doc_id, "found deleted doc when flushing, removing from redis" + callback() + else if error? logger.error err: error, project_id: project_id, doc_id: doc_id, "error flushing doc" errors.push(error) - callback() + callback() + else + callback() logger.log project_id: project_id, doc_ids: doc_ids, "flushing docs" async.series jobs, () ->