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,