fix tests

Netflix · Feb 12, 2024 · 99680bb · 99680bb
1 parent a3e36ee
commit 99680bb
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/atlas-eval/src/main/scala/com/netflix/atlas/eval/model/TimeSeriesMessage.scala b/atlas-eval/src/main/scala/com/netflix/atlas/eval/model/TimeSeriesMessage.scala
@@ -114,8 +114,8 @@ object TimeSeriesMessage {
   def apply(expr: StyleExpr, context: EvalContext, ts: TimeSeries): TimeSeriesMessage = {
     val query = expr.toString
     val offset = Strings.toString(Duration.ofMillis(expr.offset))
-    val outputTags = ts.tags ++ Map(TagKey.offset -> offset, "atlas.query" -> query)
-    val id = TaggedItem.computeId(outputTags).toString
+    val outputTags = ts.tags + (TagKey.offset -> offset)
+    val id = TaggedItem.computeId(outputTags + ("atlas.query" -> query)).toString
     val data = ts.data.bounded(context.start, context.end)
     TimeSeriesMessage(
       id,

diff --git a/atlas-eval/src/test/scala/com/netflix/atlas/eval/stream/EvaluatorSuite.scala b/atlas-eval/src/test/scala/com/netflix/atlas/eval/stream/EvaluatorSuite.scala
@@ -587,7 +587,7 @@ class EvaluatorSuite extends FunSuite {
     assertEquals(msgs.count(_.message.isInstanceOf[TimeSeriesMessage]), 1)
 
     val ts = timeSeriesMessages(msgs).head
-    assertEquals(ts.tags, Map("name" -> "foo"))
+    assertEquals(ts.tags, Map("atlas.offset" -> "0w", "name" -> "foo"))
     assertEquals(ts.data, ArrayData(Array(expected)))
   }