SIENTIAPDE-1169

chore: update dependencies and refactor logger imports

- Updated the sientia-dataops-library dependency version from 1.3.8 to 1.4.1 in requirements.txt.
- Changed image tag in values.yaml from 0.4.0 to 0.4.2.
- Refactored logger imports in multiple files to use the new observability module instead of the temporal module.
- Updated retry policy imports in various workflow files to reflect the new structure.

orchestrator/activities/email.py

@@ -9,7 +9,7 @@ with workflow.unsafe.imports_passed_through():
     import smtplib
     from typing import Any
     from sientia_do.temporal.activities.base import BaseActivity
-    from sientia_do.temporal.utils.logger import Logger
+    from sientia_do.observability.logger import Logger
     from sientia_do.notifications.handlers import NotificationHandler
     from orchestrator.utils.email_builder import EmailBuilder
     from email.mime.multipart import MIMEMultipart

orchestrator/utils/email_builder.py

@@ -1,5 +1,5 @@
 import json
-from sientia_do.temporal.utils.logger import Logger
+from sientia_do.observability.logger import Logger
 from sientia_do.notifications.models import NotificationLevel
 from jinja2 import Template
 import re

orchestrator/worker/worker.py

@@ -21,7 +21,7 @@ with workflow.unsafe.imports_passed_through():
         build_postgres_config
     )
     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 prometheus_client import start_http_server
     from orchestrator import metrics
 

orchestrator/workflows/alerts.py

@@ -4,7 +4,7 @@ with workflow.unsafe.imports_passed_through():
     from orchestrator.activities.activities import Activities
     from typing import Any
     from datetime import timedelta
-    from sientia_do.temporal.utils.policies import retry_policy
+    from sientia_do.temporal.policies import retry_policy
 
 
 @workflow.defn(name="alerts")

orchestrator/workflows/orchestrator.py

@@ -4,7 +4,7 @@ with workflow.unsafe.imports_passed_through():
     from orchestrator.activities.activities import Activities
     from typing import Any
     from datetime import timedelta
-    from sientia_do.temporal.utils.policies import retry_policy
+    from sientia_do.temporal.policies import retry_policy
 
 
 @workflow.defn(name="orchestrator")

orchestrator/workflows/reports.py

@@ -4,7 +4,7 @@ with workflow.unsafe.imports_passed_through():
     from orchestrator.activities.activities import Activities
     from typing import Any
     from datetime import timedelta
-    from sientia_do.temporal.utils.policies import retry_policy
+    from sientia_do.temporal.policies import retry_policy
 
 
 @workflow.defn(name="reports")

orchestrator/workflows/subworkflows/load_notification_package.py

@@ -3,7 +3,7 @@ from temporalio import workflow
 with workflow.unsafe.imports_passed_through():
     from orchestrator.activities.activities import Activities
     from typing import Any
-    from sientia_do.temporal.utils.policies import retry_policy
+    from sientia_do.temporal.policies import retry_policy
     from datetime import timedelta
 
 

orchestrator/workflows/subworkflows/process_notifications.py

@@ -4,7 +4,7 @@ with workflow.unsafe.imports_passed_through():
     from orchestrator.activities.activities import Activities
     from typing import Any
     from datetime import timedelta
-    from sientia_do.temporal.utils.policies import retry_policy
+    from sientia_do.temporal.policies import retry_policy
 
 
 @workflow.defn(name="process_notifications")