diff --git a/orchestrator/activities/mongo_db.py b/orchestrator/activities/mongo_db.py index e53f51a..d456d7e 100644 --- a/orchestrator/activities/mongo_db.py +++ b/orchestrator/activities/mongo_db.py @@ -10,7 +10,7 @@ with workflow.unsafe.imports_passed_through(): from sientia_do.notifications.models import NotificationLevel from sientia_do.temporal.activities.base import BaseActivity from sientia_do.temporal.constants import DATETIME_FORMAT_MS_WITH_TZ, now - from datetime import datetime + from datetime import datetime, timezone def clear_mongo_id(docs: list) -> list: @@ -459,7 +459,7 @@ class MongoDB(BaseActivity): ) for item in data: - item['timestamp'] = item['timestamp'].strftime( + item['timestamp'] = item['timestamp'].replace(tzinfo=timezone.utc).strftime( DATETIME_FORMAT_MS_WITH_TZ) self.info(