Update dependencies and refactor logger imports for observability

- Updated sientia-dataops-library version to 1.4.1 in requirements.txt.
- Changed image tag from 0.3.2 to 0.4.2 in values.yaml.
- Refactored logger imports from sientia_do.temporal.utils.logger to sientia_do.observability.logger in multiple manager files for improved observability.

ingestor/ingestor.py

@@ -3,7 +3,7 @@ from copy import deepcopy
 from typing import Dict, Any
 
 from sientia_do.notifications.handlers import CoreNotificationHandler as NotificationHandler
-from sientia_do.temporal.utils.logger import get_logger
+from sientia_do.observability.logger import get_logger
 
 from ingestor.managers.ingestor_manager import IngestorManager
 

ingestor/managers/data_manager.py

@@ -7,7 +7,7 @@ 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.activities.base import BaseActivity
-from sientia_do.temporal.utils.logger import Logger
+from sientia_do.observability.logger import Logger
 import traceback
 import ingestor.metrics as metrics
 import os

ingestor/managers/ingestor_manager.py

@@ -4,7 +4,7 @@ from copy import deepcopy
 from sientia_do.notifications.handlers import CoreNotificationHandler as NotificationHandler
 from sientia_do.notifications.models import NotificationLevel
 from sientia_do.temporal.activities.base import BaseActivity
-from sientia_do.temporal.utils.logger import Logger
+from sientia_do.observability.logger import Logger
 from ingestor.managers.data_manager import DataManager
 from ingestor.managers.opc_manager import OpcManager
 from ingestor.managers.resource_manager import ResourceManager

ingestor/managers/opc_manager.py

@@ -5,7 +5,7 @@ from asyncua.sync import Client
 from sientia_do.notifications.models import NotificationLevel
 from sientia_do.notifications.handlers import CoreNotificationHandler as NotificationHandler
 from sientia_do.temporal.activities.base import BaseActivity
-from sientia_do.temporal.utils.logger import Logger
+from sientia_do.observability.logger import Logger
 from ingestor.managers.data_manager import DataManager
 import ingestor.metrics as metrics
 

ingestor/managers/resource_manager.py

@@ -5,7 +5,7 @@ from time import time
 import ingestor.metrics as metrics
 from sientia_do.notifications.handlers import CoreNotificationHandler as NotificationHandler
 from sientia_do.notifications.models import NotificationLevel
-from sientia_do.temporal.utils.logger import Logger
+from sientia_do.observability.logger import Logger
 from sientia_do.temporal.activities.base import BaseActivity
 
 

requirements.txt

@@ -1,5 +1,5 @@
 asyncua==1.1.5
 redis
-git+ssh://git@github.com/Aignosi/sientia-dataops-library.git@1.3.8
+git+ssh://git@github.com/Aignosi/sientia-dataops-library.git@1.4.1
 prometheus_client
 pymongo

values.yaml

@@ -11,7 +11,7 @@ image:
   # This sets the pull policy for images.
   pullPolicy: Always
   # Overrides the image tag whose default is the chart appVersion.
-  tag: "0.3.2"
+  tag: "0.4.2"
 
 # This is for the secrets for pulling an image from a private repository more information can be found here: https://kubernetes.io/docs/tasks/configure-pod-container/pull-image-private-registry/
 imagePullSecrets:
@@ -158,7 +158,7 @@ env:
   - name: GITHUB_REPO_URL
     value: "git@github.com:Aignosi/sientia-dataops-opc-ingestor.git"
   - name: GITHUB_BRANCH
-    value: "SIENTIAPDE-1174-mapear-e-implementar-metricas-a-serem-criadas"
+    value: "SIENTIAPDE-1199-revisar-e-testar-observabilidade"
   - name: PYTHON_APP
     value: "ingestor.app"