diff --git a/modules/ingestor/src/main/scala/package.scala b/modules/ingestor/src/main/scala/package.scala
index 0720faa1..12354d21 100644
--- a/modules/ingestor/src/main/scala/package.scala
+++ b/modules/ingestor/src/main/scala/package.scala
@@ -34,4 +34,4 @@ extension (instant: Instant)
 def range(field: String)(since: Instant, until: Option[Instant]): Filter =
   import Filter.*
   val gtes = gte(field, since)
-  until.fold(gtes)(until => gtes.and(lt("updatedAt", until)))
+  until.fold(gtes)(until => gtes.and(lt(field, until)))