fix datetime reference in DAG.is_fixed_time_schedule (#36370)

(cherry picked from commit 547ddf6)
apache · Jan 11, 2024 · 0dba06d · 0dba06d
1 parent 8317580
commit 0dba06d
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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):