From 07ed5ebf6e70a5bffedebc3627699a98d013a7fb Mon Sep 17 00:00:00 2001 From: vincbeck Date: Fri, 5 Dec 2025 14:43:24 -0500 Subject: [PATCH] Fix newly introduced mypy error --- airflow-core/src/airflow/assets/manager.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/airflow-core/src/airflow/assets/manager.py b/airflow-core/src/airflow/assets/manager.py index 74f5ef131741e..b41013664e0d5 100644 --- a/airflow-core/src/airflow/assets/manager.py +++ b/airflow-core/src/airflow/assets/manager.py @@ -351,7 +351,7 @@ def _get_or_create_apdr( target_dag: SerializedDagModel, session: Session, ) -> AssetPartitionDagRun: - latest_apdr: AssetPartitionDagRun = session.scalar( + latest_apdr: AssetPartitionDagRun | None = session.scalar( select(AssetPartitionDagRun) .where( AssetPartitionDagRun.partition_key == target_key,