gitea_admin/sientia-dataops-orchestrator_temporal
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

SIENTIAPDE-1184

Browse Source 
fix: add conditional check for data_filter in MongoDB activity

- Updated the insert_many method to only execute if data_filter is not empty, preventing unnecessary database operations and potential errors.
This commit is contained in:
vitor-aignosi
2025-08-12 13:36:13 -03:00
parent afaf017340
commit 7fd38e1d52
2 changed files with 334 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

332
init_orchestration.ipynb Normal file
View File

File diff suppressed because one or more lines are too long

4
orchestrator/activities/mongo_db.py
View File

@@ -1,4 +1,3 @@
from pandas import DataFrame
from temporalio import workflow, activity from temporalio import workflow, activity
@@ -257,7 +256,8 @@ class MongoDB(BaseActivity):
data_filter = argument if argument else {} data_filter = argument if argument else {}
try: try:
collection.insert_many(data_filter) if data_filter:
collection.insert_many(data_filter)
except Exception as e: except Exception as e:
trace = traceback.format_exc() trace = traceback.format_exc()
self.send_notification( self.send_notification(