From d7d44556c844532fbb44e0d6a048887ce1b0fc55 Mon Sep 17 00:00:00 2001 From: vitor-aignosi Date: Tue, 1 Jul 2025 15:31:27 -0300 Subject: [PATCH] SIENTIAPDE-1110 Update MongoDB activity to handle None last_data_timestamp by using an empty filter, improving data retrieval logic. --- scouter/activities/mongodb.py | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/scouter/activities/mongodb.py b/scouter/activities/mongodb.py index 485a492..87fbc51 100644 --- a/scouter/activities/mongodb.py +++ b/scouter/activities/mongodb.py @@ -92,11 +92,14 @@ class MongoDB(BaseActivity): try: - data_filter = { - "inserted_at": { - "$gt": datetime.strptime(last_data_timestamp, "%Y-%m-%d %H:%M:%S.%f") + if last_data_timestamp is None: + data_filter = {} + else: + data_filter = { + "inserted_at": { + "$gt": datetime.strptime(last_data_timestamp, "%Y-%m-%d %H:%M:%S.%f") + } } - } data = self.database[collection_name].find(data_filter, {"_id": 0})