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

SIENTIAPDE-1445

Browse Source 
Enhance MongoDB activity to handle missing topic configurations gracefully by using get() method and skipping empty collections, improving robustness in pipeline processing.
This commit is contained in:
vitor-aignosi
2025-12-18 12:16:37 -03:00
parent 5d2d297aa2
commit 886c6362ce
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
orchestrator/activities/mongo_db.py
View File

@@ -393,7 +393,9 @@ class MongoDB(SientiaMonitoring):
created_indexes = [] created_indexes = []
for _pipeline_name, pipeline_config in pipelines.items(): for _pipeline_name, pipeline_config in pipelines.items():
collection = pipeline_config['topic'] collection = pipeline_config.get('topic', None)
if not collection:
continue
try: try:
# Check if collection exists # Check if collection exists