diff --git a/orchestrator/activities/mongo_db.py b/orchestrator/activities/mongo_db.py index e00e2c4..d96ed24 100644 --- a/orchestrator/activities/mongo_db.py +++ b/orchestrator/activities/mongo_db.py @@ -2,7 +2,7 @@ from temporalio import activity, workflow with workflow.unsafe.imports_passed_through(): import traceback - from datetime import UTC, datetime + from datetime import UTC from logging import Logger from typing import Any @@ -147,9 +147,7 @@ class MongoDB(SientiaMonitoring): raise e @activity.defn(name='aggregate_documents_in_mongodb') - def aggregate_documents_in_mongodb( - self, input_data: dict[str, Any] - ) -> list[dict[str, Any]]: + def aggregate_documents_in_mongodb(self, input_data: dict[str, Any]) -> list[dict[str, Any]]: """ Aggregate documents in a MongoDB collection based on the provided aggregation pipeline. @@ -344,9 +342,7 @@ class MongoDB(SientiaMonitoring): data_filter = {'$or': argument} if argument else {} try: - self.mongo_db_repository.delete_many( - 'orchestrated_schedules', data_filter, metadata - ) + self.mongo_db_repository.delete_many('orchestrated_schedules', data_filter, metadata) except Exception as e: trace = traceback.format_exc() self.send_notification( diff --git a/orchestrator/worker/worker.py b/orchestrator/worker/worker.py index f1ff504..3c9d9ba 100644 --- a/orchestrator/worker/worker.py +++ b/orchestrator/worker/worker.py @@ -136,7 +136,7 @@ async def main(): activities.report_slot_orchestration, activities.format_schedule_config, ], - logger=logger + logger=logger, ), prepare_worker( temporal_client=temporal_client, @@ -158,7 +158,7 @@ async def main(): # Store notification cache activities.store_notification_cache, ], - logger=logger + logger=logger, ), prepare_worker( temporal_client=temporal_client, @@ -178,7 +178,7 @@ async def main(): activities.format_log_report, activities.export_data_to_postgres, ], - logger=logger + logger=logger, ), ] diff --git a/values.yaml b/values.yaml index 51ccce4..24ee977 100644 --- a/values.yaml +++ b/values.yaml @@ -164,7 +164,7 @@ env: - name: GITHUB_REPO_URL value: "git@github.com:Aignosi/sientia-dataops-orchestrator_temporal.git" - name: GITHUB_BRANCH - value: "fix/SIENTIAPDE-1712" + value: "feature/SIENTIAPDE-1646" - name: PYTHON_APP value: "orchestrator.worker.worker" @@ -263,3 +263,5 @@ ssh: # kubectl create secret generic smtp-credentials \ # --namespace sientia \ # --from-literal=app_password='sua-senha-de-app-de-16-digitos' + +# helm upgrade --install sientia-orchestrator-worker /home/grezewave/Documents/projects/sientia/sientia-core-applications/sientia-module -n sientia --create-namespace -f ./values.yaml \ No newline at end of file