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

SIENTIAPDE-1712

Browse Source 
Fix error model retrieval in notification_generator.ipynb and add on_conflict parameter to common_config in orchestrator_functions.py for improved error handling.
This commit is contained in:
vitor-aignosi
2026-03-27 14:09:48 -03:00
parent 4f5832cfb3
commit e7705964d5
2 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
notification_generator.ipynb
View File

@@ -151,7 +151,7 @@
} }
], ],
"source": [ "source": [
"error_models = general_events.get('ERROR', {}).get('models', [])\n", "error_models = general_events.get('ERROR', {}).get('', [])\n",
"warning_models = general_events.get('WARNING', {}).get('models', [])\n", "warning_models = general_events.get('WARNING', {}).get('models', [])\n",
"info_models = general_events.get('INFO', {}).get('models', [])\n", "info_models = general_events.get('INFO', {}).get('models', [])\n",
"mail_type = 'Alerts'\n", "mail_type = 'Alerts'\n",

1
orchestrator/utils/orchestrator_functions.py
View File

@@ -38,6 +38,7 @@ def common_config(config: dict[str, Any]):
'model_config': model.get('model_config', {}), 'model_config': model.get('model_config', {}),
'execution_timeout_seconds': config.get('execution_timeout_seconds', 300), 'execution_timeout_seconds': config.get('execution_timeout_seconds', 300),
'task_timeout_seconds': config.get('task_timeout_seconds', 300), 'task_timeout_seconds': config.get('task_timeout_seconds', 300),
'on_conflict': config.get('on_conflict', 'error'),
} }