This is an automated email from the ASF dual-hosted git repository.
vincbeck 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 13baf17b933 Fix mypy error in `airflow-core/src/airflow/models/dag`
(#58902)
13baf17b933 is described below
commit 13baf17b933def063b9df0bae1a047b9e4f98880
Author: Vincent <[email protected]>
AuthorDate: Mon Dec 1 11:19:00 2025 -0500
Fix mypy error in `airflow-core/src/airflow/models/dag` (#58902)
---
airflow-core/src/airflow/models/dag.py | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git a/airflow-core/src/airflow/models/dag.py
b/airflow-core/src/airflow/models/dag.py
index 16ce63aab9e..852ec45d8fb 100644
--- a/airflow-core/src/airflow/models/dag.py
+++ b/airflow-core/src/airflow/models/dag.py
@@ -23,6 +23,7 @@ from collections.abc import Callable, Collection
from datetime import datetime, timedelta
from typing import TYPE_CHECKING, Any, TypeVar, Union, cast
+import pendulum
import sqlalchemy_jsonfield
from dateutil.relativedelta import relativedelta
from sqlalchemy import (
@@ -136,7 +137,9 @@ def get_run_data_interval(timetable: Timetable, run:
DagRun) -> DataInterval:
) is not None:
return data_interval
- if (data_interval :=
timetable.infer_manual_data_interval(run_after=run.run_after)) is not None:
+ if (
+ data_interval :=
timetable.infer_manual_data_interval(run_after=pendulum.instance(run.run_after))
+ ) is not None:
return data_interval
# Compatibility: runs created before AIP-39 implementation don't have an
