diff --git a/services/real-time/app.coffee b/services/real-time/app.coffee index 61db94ca94..708e5f467c 100644 --- a/services/real-time/app.coffee +++ b/services/real-time/app.coffee @@ -130,7 +130,7 @@ if Settings.shutdownDrainTimeWindow? return else Settings.shutDownInProgress = true - logger.log signal: signal, "received interrupt, starting drain over #{shutdownDrainTimeWindow} mins" + logger.warn signal: signal, "received interrupt, starting drain over #{shutdownDrainTimeWindow} mins" DrainManager.startDrainTimeWindow(io, shutdownDrainTimeWindow) shutdownCleanly(signal) diff --git a/services/real-time/app/coffee/DrainManager.coffee b/services/real-time/app/coffee/DrainManager.coffee index 2219291267..ad142ccc47 100644 --- a/services/real-time/app/coffee/DrainManager.coffee +++ b/services/real-time/app/coffee/DrainManager.coffee @@ -9,6 +9,7 @@ module.exports = DrainManager = startDrain: (io, rate) -> # Clear out any old interval clearInterval @interval + logger.log rate: rate, "starting drain" if rate == 0 return else if rate < 1