Add await for poller counters flush

nielm · Dec 8, 2023 · 1ed871e · 1ed871e
1 parent 6fc6e0e
commit 1ed871e
Showing 1 changed file with 3 additions and 3 deletions.
diff --git 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();
   }
 };