atlas cloudwatch: Fix tagging of routing queue metric. (Netflix-Skunk…

…works#442)
manolama · Oct 25, 2023 · 759db97 · 759db97
1 parent 47b8312
commit 759db97
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 3 deletions.
diff --git a/atlas-cloudwatch/src/main/scala/com/netflix/atlas/cloudwatch/PublishRouter.scala b/atlas-cloudwatch/src/main/scala/com/netflix/atlas/cloudwatch/PublishRouter.scala
@@ -81,7 +81,7 @@ class PublishRouter(
                   r.getKey -> new PublishQueue(
                     config.getConfig("atlas.cloudwatch.account.routing"),
                     registry,
-                    destination,
+                    stack + "-" + destination,
                     baseURI
                       .replaceAll("\\$\\{STACK\\}", stack)
                       .replaceAll("\\$\\{REGION}", destination),

diff --git a/atlas-cloudwatch/src/test/scala/com/netflix/atlas/cloudwatch/PublishRouterSuite.scala b/atlas-cloudwatch/src/test/scala/com/netflix/atlas/cloudwatch/PublishRouterSuite.scala
@@ -26,8 +26,6 @@ import com.typesafe.config.ConfigFactory
 import munit.FunSuite
 import org.mockito.MockitoSugar.mock
 
-import scala.jdk.CollectionConverters.CollectionHasAsScala
-
 class PublishRouterSuite extends FunSuite with TestKitBase {
 
   override implicit def system: ActorSystem = ActorSystem(getClass.getSimpleName)