SIENTIAPDE-1193
Update replica count in values.yaml to 1 and enhance timestamp handling in MongoDB activity by setting timezone to UTC for inserted_at field.
This commit is contained in:
@@ -3,7 +3,7 @@ from temporalio import workflow, activity
|
||||
with workflow.unsafe.imports_passed_through():
|
||||
from typing import Any
|
||||
import traceback
|
||||
from datetime import datetime
|
||||
from datetime import datetime, timezone
|
||||
from pymongo import MongoClient
|
||||
from pandas import DataFrame
|
||||
from sientia_do.notifications.handlers import CoreNotificationHandler as NotificationHandler
|
||||
@@ -120,8 +120,8 @@ class MongoDB(BaseActivity):
|
||||
)
|
||||
|
||||
for item in data:
|
||||
item['inserted_at'] = item['inserted_at'].strftime(
|
||||
DATETIME_FORMAT_MS_WITH_TZ)
|
||||
item['inserted_at'] = item['inserted_at'].replace(
|
||||
tzinfo=timezone.utc).strftime(DATETIME_FORMAT_MS_WITH_TZ)
|
||||
|
||||
self.info(
|
||||
f"Loaded {len(data)} documents from MongoDB",
|
||||
|
||||
Reference in New Issue
Block a user