diff --git a/orchestrator/activities/formatters.py b/orchestrator/activities/formatters.py index 1c021cc..ca1e1f1 100644 --- a/orchestrator/activities/formatters.py +++ b/orchestrator/activities/formatters.py @@ -164,11 +164,15 @@ class Formatters(BaseActivity): """ for schedule_name, schedule in schedules.items(): if schedule_name in current_schedules: + update_timestamp = schedule.get( 'updated_at', datetime.now().strftime(DEFAULT_DATE_FORMAT)) old_timestamp = current_schedules[schedule_name] + self.logger.debug( + f"Comparing schedule {schedule_name}:{update_timestamp} vs {old_timestamp}") + if update_timestamp > old_timestamp: to_update[namespace][schedule_name] = schedule else: