diff --git a/src/poller/poller-core/index.js b/src/poller/poller-core/index.js index 941b767d..74338616 100644 --- a/src/poller/poller-core/index.js +++ b/src/poller/poller-core/index.js @@ -573,7 +573,7 @@ exports.checkSpannerScaleMetricsPubSub = async (pubSubEvent, context) => { log(`JSON payload`, {severity: 'ERROR', payload: payload}); Counters.incPollingFailedCounter(); } finally { - Counters.tryFlush(); + await Counters.tryFlush(); } }; @@ -608,7 +608,7 @@ exports.checkSpannerScaleMetricsHTTP = async (req, res) => { res.end(err.toString()); Counters.incPollingFailedCounter(); } finally { - Counters.tryFlush(); + await Counters.tryFlush(); } }; @@ -630,7 +630,7 @@ exports.checkSpannerScaleMetricsJSON = async (payload) => { log(`JSON payload`, {severity: 'ERROR', payload: payload}); Counters.incPollingFailedCounter(); } finally { - Counters.tryFlush(); + await Counters.tryFlush(); } };