Replacing usage of 'consuming_dags' with 'scheduled_dags' in AssetAliasModel (apache#51864)

amoghrajesh · RoyLee1224 · commit caa41e05d004 · 2025-06-22T02:15:57.000+09:00
diff --git a/airflow-core/src/airflow/jobs/scheduler_job_runner.py b/airflow-core/src/airflow/jobs/scheduler_job_runner.py
@@ -1591,7 +1591,7 @@ def _create_dag_runs_asset_triggered(
                             )
                         ),
                         AssetEvent.source_aliases.any(
-                            AssetAliasModel.consuming_dags.any(
+                            AssetAliasModel.scheduled_dags.any(
                                 DagScheduleAssetAliasReference.dag_id == dag.dag_id
                             )
                         ),

Original file line number	Diff line number	Diff line change
`@@ -1591,7 +1591,7 @@ def _create_dag_runs_asset_triggered(`
`1591`	`1591`	`)`
`1592`	`1592`	`),`
`1593`	`1593`	`AssetEvent.source_aliases.any(`
`1594`		`- AssetAliasModel.consuming_dags.any(`
	`1594`	`+ AssetAliasModel.scheduled_dags.any(`
`1595`	`1595`	`DagScheduleAssetAliasReference.dag_id == dag.dag_id`
`1596`	`1596`	`)`
`1597`	`1597`	`),`