Lee-W commented on code in PR #61831:
URL: https://github.com/apache/airflow/pull/61831#discussion_r2802992055
##########
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,
Review Comment:
Unfortunately, it's not that easy because many related PRs haven't been
merged. I'll merge this one and add a unit test in a follow up PR once most of
the existing PRs merged
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
