From ae573daae5ed315658e515f20cc194b0055251be Mon Sep 17 00:00:00 2001 From: vincbeck Date: Mon, 8 Dec 2025 10:41:18 -0500 Subject: [PATCH] Fix mypy error in `scheduler_job_runner.py` --- airflow-core/src/airflow/jobs/scheduler_job_runner.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/airflow-core/src/airflow/jobs/scheduler_job_runner.py b/airflow-core/src/airflow/jobs/scheduler_job_runner.py index e50af60db88e0..5d8df8e970ef1 100644 --- a/airflow-core/src/airflow/jobs/scheduler_job_runner.py +++ b/airflow-core/src/airflow/jobs/scheduler_job_runner.py @@ -1679,6 +1679,8 @@ def _create_dagruns_for_partitioned_asset_dags(self, session: Session) -> set[st select(AssetPartitionDagRun).where(AssetPartitionDagRun.created_dag_run_id.is_(None)) ) for apdr in apdrs: + if TYPE_CHECKING: + assert apdr.target_dag_id partition_dag_ids.add(apdr.target_dag_id) dag = _get_current_dag(dag_id=apdr.target_dag_id, session=session) if not dag: