From 95d35ebde5e8b6d09863742333bd6d0f2d9839e5 Mon Sep 17 00:00:00 2001 From: Josh Owen Date: Fri, 22 Dec 2023 11:20:43 -0500 Subject: [PATCH] fix datetime reference in DAG.is_fixed_time_schedule --- airflow/models/dag.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/airflow/models/dag.py b/airflow/models/dag.py index 9150adaf6ff4f..d0f46feed2bfc 100644 --- a/airflow/models/dag.py +++ b/airflow/models/dag.py @@ -874,8 +874,8 @@ def is_fixed_time_schedule(self): from croniter import croniter cron = croniter(self.timetable._expression) - next_a = cron.get_next(datetime.datetime) - next_b = cron.get_next(datetime.datetime) + next_a = cron.get_next(datetime) + next_b = cron.get_next(datetime) return next_b.minute == next_a.minute and next_b.hour == next_a.hour def following_schedule(self, dttm):