[StatsFetch] Ignore bad decodes

airbnb · Feb 1, 2024 · ac73f57 · ac73f57
1 parent 9bee3dc
commit ac73f57
Showing 1 changed file with 10 additions and 8 deletions.
diff --git a/online/src/main/scala/ai/chronon/online/Fetcher.scala b/online/src/main/scala/ai/chronon/online/Fetcher.scala
@@ -462,14 +462,16 @@ class Fetcher(val kvStore: KVStore,
     rawResponses.map { responseFuture =>
       val convertedValue = responseFuture
         .flatMap { response =>
-          response.values.get.map {
-            case (key, v) =>
-              key ->
-                Map(
-                  "millis" -> response.millis.asInstanceOf[AnyRef],
-                  "value" -> StatsGenerator.SeriesFinalizer(key, v)
-                ).asJava
-          }
+          response.values
+            .getOrElse(Map.empty[String, AnyRef])
+            .map {
+              case (key, v) =>
+                key ->
+                  Map(
+                    "millis" -> response.millis.asInstanceOf[AnyRef],
+                    "value" -> StatsGenerator.SeriesFinalizer(key, v)
+                  ).asJava
+            }
         }
         .groupBy(_._1)
         .mapValues(_.map(_._2).toList.asJava)