diff --git a/services/document-updater/app/coffee/DispatchManager.coffee b/services/document-updater/app/coffee/DispatchManager.coffee index b7e50291b0..4444c0183b 100644 --- a/services/document-updater/app/coffee/DispatchManager.coffee +++ b/services/document-updater/app/coffee/DispatchManager.coffee @@ -20,7 +20,9 @@ module.exports = DispatchManager = [list_name, doc_key] = result [project_id, doc_id] = Keys.splitProjectIdAndDocId(doc_key) # Dispatch this in the background + Metrics.gauge "processingUpdates", "+1" # increments/decrements gauge with +/- sign UpdateManager.processOutstandingUpdatesWithLock project_id, doc_id, (error) -> + Metrics.gauge "processingUpdates", "-1" logger.error err: error, project_id: project_id, doc_id: doc_id, "error processing update" if error? callback() @@ -39,4 +41,4 @@ module.exports = DispatchManager = createAndStartDispatchers: (number) -> for i in [1..number] worker = DispatchManager.createDispatcher() - worker.run() \ No newline at end of file + worker.run()