Database: Update index usage.

CESNET · Jul 12, 2024 · 4d7f4a2 · 4d7f4a2
1 parent 90e7e90
commit 4d7f4a2
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/dp3/database/database.py b/dp3/database/database.py
@@ -476,7 +476,7 @@ def delete_old_dps(self, etype: str, attr_name: str, t_old: datetime) -> None:
         master_col = self._master_col_name(etype)
         try:
             self._db[master_col].update_many(
-                {attr_name: {"$exists": True}}, {"$pull": {attr_name: {"t2": {"$lt": t_old}}}}
+                {f"{attr_name}.t2": {"$lt": t_old}}, {"$pull": {attr_name: {"t2": {"$lt": t_old}}}}
             )
         except Exception as e:
             raise DatabaseError(f"Delete of old datapoints failed: {e}") from e