Skip to content

Commit a355eb5

Browse files
committed
test fix
1 parent 8104df3 commit a355eb5

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

online/src/main/scala/ai/chronon/online/fetcher/GroupByResponseHandler.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -249,8 +249,8 @@ class GroupByResponseHandler(fetchContext: FetchContext, metadataStore: Metadata
249249
case batchTimedValuesTry: KvStoreBatchResponse =>
250250
batchTimedValuesTry.response match {
251251

252-
case Failure(_) => existingServingInfo
253-
case Success(value) if value.isEmpty => existingServingInfo
252+
case Failure(_) => existingServingInfo
253+
case Success(value) if value == null || value.isEmpty => existingServingInfo
254254

255255
case Success(value) if value.iterator.map(_.millis).max <= existingServingInfo.batchEndTsMillis =>
256256
existingServingInfo

0 commit comments

Comments
 (0)