From 0bdd7f541006c173cda7ba1352534509acd9d23e Mon Sep 17 00:00:00 2001 From: vitor-aignosi Date: Fri, 22 Aug 2025 13:59:11 -0300 Subject: [PATCH] SIENTIAPDE-1193 Update requirements and refactor timestamp handling in DataManager - Updated sientia-dataops-library version to 1.4.3 in requirements.txt. - Refactored timestamp insertion in DataManager to use the now() function for improved consistency. --- ingestor/managers/data_manager.py | 4 ++-- requirements.txt | 3 +-- 2 files changed, 3 insertions(+), 4 deletions(-) diff --git a/ingestor/managers/data_manager.py b/ingestor/managers/data_manager.py index ad65367..28fe065 100644 --- a/ingestor/managers/data_manager.py +++ b/ingestor/managers/data_manager.py @@ -1,11 +1,11 @@ import json from time import sleep -from datetime import datetime, timezone from pymongo import MongoClient from kafka import KafkaProducer from kafka.errors import NoBrokersAvailable from sientia_do.notifications.handlers import CoreNotificationHandler as NotificationHandler from sientia_do.notifications.models import NotificationLevel +from sientia_do.temporal.constants import now from sientia_do.temporal.activities.base import BaseActivity from sientia_do.observability.logger import Logger import traceback @@ -184,7 +184,7 @@ class DataManager(BaseActivity): collection.insert_one( { **data, - "inserted_at": datetime.now(timezone.utc), + "inserted_at": now(), } ) self.logger.debug( diff --git a/requirements.txt b/requirements.txt index eb2b3bd..ecc7949 100644 --- a/requirements.txt +++ b/requirements.txt @@ -1,6 +1,5 @@ asyncua==1.1.5 redis -# git+ssh://git@github.com/Aignosi/sientia-dataops-library.git@1.4.1 -/home/grezewave/Documents/projects/sientia/sientia-dataops-library +git+ssh://git@github.com/Aignosi/sientia-dataops-library.git@1.4.3 prometheus_client pymongo \ No newline at end of file