diff --git a/airflow-core/src/airflow/jobs/scheduler_job_runner.py b/airflow-core/src/airflow/jobs/scheduler_job_runner.py
index 5556965630945..45927314ccfbc 100644
--- a/airflow-core/src/airflow/jobs/scheduler_job_runner.py
+++ b/airflow-core/src/airflow/jobs/scheduler_job_runner.py
@@ -1804,6 +1804,7 @@ def _create_dagruns_for_partitioned_asset_dags(self, session: Session) -> set[st
                         select(1).where(
                             PartitionedAssetKeyLog.asset_id == AssetModel.id,
                             PartitionedAssetKeyLog.asset_partition_dag_run_id == apdr.id,
+                            PartitionedAssetKeyLog.target_partition_key == apdr.partition_key,
                         )
                     )
                 )