gitea_admin/sientia-dataops-orchestrator_temporal
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

SIENTIAPDE-1205

Browse Source 
SIENTIAPDE-1205: Refactor timestamp handling in MongoDB activities

- Updated the import statement in mongo_db.py to include timezone support.
- Modified timestamp formatting to ensure UTC timezone is applied before string conversion, enhancing consistency in datetime handling.
This commit is contained in:
vitor-aignosi
2025-08-27 09:32:42 -03:00
parent 93915841d6
commit 2a3e5b8bc4
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
orchestrator/activities/mongo_db.py
View File

@@ -10,7 +10,7 @@ with workflow.unsafe.imports_passed_through():
from sientia_do.notifications.models import NotificationLevel from sientia_do.notifications.models import NotificationLevel
from sientia_do.temporal.activities.base import BaseActivity from sientia_do.temporal.activities.base import BaseActivity
from sientia_do.temporal.constants import DATETIME_FORMAT_MS_WITH_TZ, now 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: def clear_mongo_id(docs: list) -> list:
@@ -459,7 +459,7 @@ class MongoDB(BaseActivity):
) )
for item in data: for item in data:
item['timestamp'] = item['timestamp'].strftime( item['timestamp'] = item['timestamp'].replace(tzinfo=timezone.utc).strftime(
DATETIME_FORMAT_MS_WITH_TZ) DATETIME_FORMAT_MS_WITH_TZ)
self.info( self.info(