SIENTIAPDE-1171
SIENTIAPDE-1171 feat: add minimal retrain schedule configuration to samples.json and update formatters.py - Added a new schedule configuration for the minimal retrain pipeline in samples.json. - Updated the Formatters class in formatters.py to handle the new minimal retrain workflow type, integrating the minimal_retrain function for streamlined processing.
This commit is contained in:
@@ -1,6 +1,8 @@
|
||||
|
||||
from temporalio import activity, workflow
|
||||
|
||||
from orchestrator.utils.orchestrator_functions import minimal_retrain
|
||||
|
||||
|
||||
with workflow.unsafe.imports_passed_through():
|
||||
import json
|
||||
@@ -67,6 +69,13 @@ class Formatters(BaseActivity):
|
||||
"updated_at": pipeline.get(
|
||||
"updated_at", datetime.now().strftime(DEFAULT_DATE_FORMAT))
|
||||
}
|
||||
elif pipeline['workflow_type'] == 'minimal_retrain':
|
||||
schedule_config[self.laborious_namespace][pipeline['schedule_name']
|
||||
] = {
|
||||
**minimal_retrain(pipeline),
|
||||
"updated_at": pipeline.get(
|
||||
"updated_at", datetime.now().strftime(DEFAULT_DATE_FORMAT))
|
||||
}
|
||||
|
||||
self.info("Processed schedules", metadata=metadata)
|
||||
self.debug(json.dumps(
|
||||
|
||||
Reference in New Issue
Block a user