This is an automated email from the ASF dual-hosted git repository.
husseinawala pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 547ddf6317 fix datetime reference in DAG.is_fixed_time_schedule
(#36370)
547ddf6317 is described below
commit 547ddf6317b3fc93e766b61daf11308b552e6d6b
Author: Josh Owen <[email protected]>
AuthorDate: Fri Dec 22 18:08:16 2023 -0500
fix datetime reference in DAG.is_fixed_time_schedule (#36370)
---
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 9150adaf6f..d0f46feed2 100644
--- a/airflow/models/dag.py
+++ b/airflow/models/dag.py
@@ -874,8 +874,8 @@ class DAG(LoggingMixin):
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):
