From a58f00a23b8bc6a15d9e0a3092163be06832336d Mon Sep 17 00:00:00 2001 From: Bohdan Date: Fri, 28 Jul 2023 18:55:25 +0300 Subject: [PATCH] Add resetting seconds and microseconds that fixes losing runs by CronTriggerTimetable --- airflow/timetables/trigger.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/airflow/timetables/trigger.py b/airflow/timetables/trigger.py index 7807542da5a63..36c638d8eeeb8 100644 --- a/airflow/timetables/trigger.py +++ b/airflow/timetables/trigger.py @@ -89,7 +89,7 @@ def next_dagrun_info( else: next_start_time = self._align_to_next(restriction.earliest) else: - start_time_candidates = [self._align_to_next(DateTime.utcnow())] + start_time_candidates = [self._align_to_next(DateTime.utcnow().replace(second=0, microsecond=0))] if last_automated_data_interval is not None: start_time_candidates.append(self._get_next(last_automated_data_interval.end)) if restriction.earliest is not None: