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