Fix updateRegistry bug to pass Counter only for DsType.Rate (#594)

Netflix-Skunkworks · Oct 17, 2024 · 52e5077 · 52e5077
1 parent a788f2b
commit 52e5077
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/atlas-cloudwatch/src/main/scala/com/netflix/atlas/cloudwatch/PublishQueue.scala b/atlas-cloudwatch/src/main/scala/com/netflix/atlas/cloudwatch/PublishQueue.scala
@@ -112,8 +112,8 @@ class PublishQueue(
 
   def updateRegistry(dp: AtlasDatapoint, cwDatapoint: CloudWatchDatapoint): Unit = {
     val atlasDp = toDoubleValue(dp)
-    registryPublishClient.updateCounter(atlasDp.id, atlasDp.value)
     if (dp.dsType == DsType.Rate) {
+      registryPublishClient.updateCounter(atlasDp.id, atlasDp.value)
       registry
         .counter(
           updateSelfMetrics(dp, cwDatapoint)