diff --git a/orchestrator/activities/formatters.py b/orchestrator/activities/formatters.py index 834826f..1c021cc 100644 --- a/orchestrator/activities/formatters.py +++ b/orchestrator/activities/formatters.py @@ -53,11 +53,18 @@ class Formatters(BaseActivity): for pipeline in pipelines: if pipeline['workflow_type'] == 'scouter': - schedule_config[self.scouter_namespace][pipeline['schedule_name']] = scouter( - pipeline) + schedule_config[self.scouter_namespace][pipeline['schedule_name']] = { + **scouter(pipeline), + "updated_at": pipeline.get( + "updated_at", datetime.now().strftime(DEFAULT_DATE_FORMAT)) + } elif pipeline['workflow_type'] == 'predictions_batch': schedule_config[self.laborious_namespace][pipeline['schedule_name'] - ] = predictions_batch(pipeline) + ] = { + **predictions_batch(pipeline), + "updated_at": pipeline.get( + "updated_at", datetime.now().strftime(DEFAULT_DATE_FORMAT)) + } self.logger.info("Processed schedules")