[StatsFetch] Allow for missing values on drift

airbnb · Feb 8, 2024 · f89862d · f89862d
1 parent ac5095b
commit f89862d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/online/src/main/scala/ai/chronon/online/Fetcher.scala b/online/src/main/scala/ai/chronon/online/Fetcher.scala
@@ -494,7 +494,7 @@ class Fetcher(val kvStore: KVStore,
         .sortBy(_.millis)
         .sliding(2)
         .collect {
-          case Seq(prev, curr) =>
+          case Seq(prev, curr) if prev.values.isSuccess && curr.values.isSuccess =>
             val commonKeys = prev.values.get.keySet.intersect(curr.values.get.keySet.filter(_.endsWith("percentile")))
             commonKeys
               .map { key =>