(airflow) branch main updated: Fix mypy error in `airflow-core/src/airflow/models/dag` (#58902)

[vi...@apache.org]

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 <97...@users.noreply.github.com>
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