You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by po...@apache.org on 2025/06/18 05:51:25 UTC
(airflow) branch main updated: Replacing usage of 'consuming_dags' with 'scheduled_dags' in AssetAliasModel (#51864)
This is an automated email from the ASF dual-hosted git repository.
potiuk pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 341c7739429 Replacing usage of 'consuming_dags' with 'scheduled_dags' in AssetAliasModel (#51864)
341c7739429 is described below
commit 341c7739429868718baafad2b52d6a0a64c20816
Author: Amogh Desai <am...@gmail.com>
AuthorDate: Wed Jun 18 11:21:19 2025 +0530
Replacing usage of 'consuming_dags' with 'scheduled_dags' in AssetAliasModel (#51864)
---
airflow-core/src/airflow/jobs/scheduler_job_runner.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/airflow-core/src/airflow/jobs/scheduler_job_runner.py b/airflow-core/src/airflow/jobs/scheduler_job_runner.py
index fb65a00282c..0cc71bf19b4 100644
--- a/airflow-core/src/airflow/jobs/scheduler_job_runner.py
+++ b/airflow-core/src/airflow/jobs/scheduler_job_runner.py
@@ -1591,7 +1591,7 @@ class SchedulerJobRunner(BaseJobRunner, LoggingMixin):
)
),
AssetEvent.source_aliases.any(
- AssetAliasModel.consuming_dags.any(
+ AssetAliasModel.scheduled_dags.any(
DagScheduleAssetAliasReference.dag_id == dag.dag_id
)
),