Skip to content

Commit a117d33

Browse files
committed
HistoryManager: Fixed plain attribute archivation.
1 parent 71cc702 commit a117d33

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

dp3/database/database.py

+2-2
Original file line numberDiff line numberDiff line change
@@ -1004,7 +1004,7 @@ def get_raw(
10041004
raw_col_name = self._raw_col_name(etype)
10051005
query_filter = {"$or": [{"t1": {"$gte": after, "$lt": before}}]}
10061006
if plain:
1007-
query_filter["$or"].append({"t1": {"$exists": False}})
1007+
query_filter["$or"].append({"t1": None})
10081008
return self._db[raw_col_name].find(query_filter)
10091009

10101010
def delete_old_raw_dps(self, etype: str, before: datetime, plain: bool = True):
@@ -1015,7 +1015,7 @@ def delete_old_raw_dps(self, etype: str, before: datetime, plain: bool = True):
10151015
raw_col_name = self._raw_col_name(etype)
10161016
query_filter = {"$or": [{"t1": {"$lt": before}}]}
10171017
if plain:
1018-
query_filter["$or"].append({"t1": {"$exists": False}})
1018+
query_filter["$or"].append({"t1": None})
10191019
try:
10201020
return self._db[raw_col_name].delete_many(query_filter)
10211021
except Exception as e:

0 commit comments

Comments
 (0)