SIENTIAPDE-1171

feat: add minimal_retrain function to orchestrator_functions.py for retraining workflows

- Introduced minimal_retrain function to streamline retraining configuration.
- The function integrates common configuration with specific parameters for retraining workflows.
This commit is contained in:
vitor-aignosi
2025-07-23 12:26:36 -03:00
parent ff683eea14
commit 5a4d6c5706

View File

@@ -13,6 +13,17 @@ def common_config(config: dict[str, Any]):
}
def minimal_retrain(config: dict[str, Any]):
return {
**common_config(config),
"workflow_type": "retrain",
"schedule_name": config['schedule_name'],
"query": config['query'],
"schema": "sientia_data",
"table_name": "log_retrain",
}
def scouter(config: dict[str, Any]):
filters = {}
for f in config.get('filters', []):