Update firestore filtering

kernelci · Nov 30, 2023 · f777707 · f777707
1 parent 92b925f
commit f777707
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/kcidb/monitor/spool/__init__.py b/kcidb/monitor/spool/__init__.py
@@ -238,8 +238,9 @@ def wipe(self, until=None):
             isinstance(until, datetime.datetime) and until.tzinfo
         if until is None:
             until = datetime.datetime.now(datetime.timezone.utc)
+        filter_condition = [("created_at", "<=", until)]
         for snapshot in \
-            self._get_coll().where("created_at", "<=", until). \
+            self._get_coll().where(filter=filter_condition). \
                 select([]).stream():
             snapshot.reference.delete()