This is an automated email from the ASF dual-hosted git repository.
bbovenzi 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 36b92345b9 fix(view): set "has_outlet_datasets" to true if "dataset
alias" exists (#41091)
36b92345b9 is described below
commit 36b92345b91e777f64dd860a740241a89c1232fc
Author: Wei Lee <weilee...@gmail.com>
AuthorDate: Tue Jul 30 00:28:53 2024 +0800
fix(view): set "has_outlet_datasets" to true if "dataset alias" exists
(#41091)
---
airflow/www/views.py | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git a/airflow/www/views.py b/airflow/www/views.py
index 6990890fe0..f98702ff6e 100644
--- a/airflow/www/views.py
+++ b/airflow/www/views.py
@@ -90,7 +90,7 @@ from airflow.api.common.mark_tasks import (
from airflow.auth.managers.models.resource_details import AccessView,
DagAccessEntity, DagDetails
from airflow.compat.functools import cache
from airflow.configuration import AIRFLOW_CONFIG, conf
-from airflow.datasets import Dataset
+from airflow.datasets import Dataset, DatasetAlias
from airflow.exceptions import (
AirflowConfigException,
AirflowException,
@@ -459,7 +459,9 @@ def dag_to_grid(dag: DagModel, dag_runs: Sequence[DagRun],
session: Session) ->
"label": item.label,
"extra_links": item.extra_links,
"is_mapped": item_is_mapped,
- "has_outlet_datasets": any(isinstance(i, Dataset) for i in
(item.outlets or [])),
+ "has_outlet_datasets": any(
+ isinstance(i, (Dataset, DatasetAlias)) for i in
(item.outlets or [])
+ ),
"operator": item.operator_name,
"trigger_rule": item.trigger_rule,
**setup_teardown_type,
