(airflow) branch main updated: fix(view): set "has_outlet_datasets" to true if "dataset alias" exists (#41091)

[bbovenzi]

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,