From b199cc2845251739470cb6ce1ba9197d175907c6 Mon Sep 17 00:00:00 2001 From: Wei Lee Date: Thu, 12 Feb 2026 16:10:26 +0800 Subject: [PATCH] fix: apply missing partition_key filter in PALK when creating DagRun --- airflow-core/src/airflow/jobs/scheduler_job_runner.py | 1 + 1 file changed, 1 insertion(+) 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, ) ) )