diff --git a/scouter/activities/mongodb.py b/scouter/activities/mongodb.py index 81370db..a85ea71 100644 --- a/scouter/activities/mongodb.py +++ b/scouter/activities/mongodb.py @@ -4,7 +4,7 @@ with workflow.unsafe.imports_passed_through(): from typing import Any import traceback from logging import Logger - import datetime + from datetime import datetime from pymongo import MongoClient from sientia_do.notifications.handlers import NotificationHandler from sientia_do.notifications.models import NotificationLevel @@ -97,6 +97,9 @@ class MongoDB(BaseActivity): data = clear_mongo_id(data) + for item in data: + item['inserted_at'] = item['inserted_at'].isoformat() + self.info( f"Loaded {len(data)} documents from MongoDB", metadata=metadata