fix(view): set "has_outlet_datasets" to true if "dataset alias" exists (

#41091)
apache · Jul 29, 2024 · 36b9234 · 36b9234
1 parent 815d112
commit 36b9234
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/airflow/www/views.py b/airflow/www/views.py
@@ -90,7 +90,7 @@
 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 set_overall_state(record):
                 "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,