diff --git a/elementary/monitor/fetchers/lineage/lineage.py b/elementary/monitor/fetchers/lineage/lineage.py index 06561be92..d4bc81925 100644 --- a/elementary/monitor/fetchers/lineage/lineage.py +++ b/elementary/monitor/fetchers/lineage/lineage.py @@ -31,6 +31,8 @@ def get_nodes_depends_on_nodes( sub_type=self.get_node_sub_type(node), ) for node in nodes + # Ephemeral models are not included in the lineage graph. + if node["materialization"] != "ephemeral" ] @staticmethod