yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-11-10 07:53:35 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix: Looker cll parsing issue (#21630)

Browse Source 
* Fix: Looker cll parsing issue

* Added checks
This commit is contained in:
Suman Maharana 2025-06-07 12:21:32 +05:30 committed by SumanMaharana
parent c201d52dbc
commit 3f9ec7b2e3
1 changed files with 17 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
ingestion/src/metadata/ingestion/source/dashboard/looker/metadata.py
View File

@ -880,15 +880,23 @@ class LookerSource(DashboardServiceSource):
self._parsed_views[view_name] = sql_query self._parsed_views[view_name] = sql_query
for from_table_name in lineage_parser.source_tables: for from_table_name in lineage_parser.source_tables:
# Process column level lineage # Process column level lineage
column_lineage = [ column_lineage = []
( for column_tuple in lineage_parser.column_lineage or []:
source_col.raw_name, if (
target_col.raw_name, column_tuple
) and hasattr(column_tuple[0], "parent")
for source_col, target_col in lineage_parser.column_lineage and column_tuple[0].parent == from_table_name
or [] ):
if source_col.parent == from_table_name column_lineage.append(
] (
column_tuple[0].raw_name
if hasattr(column_tuple[0], "raw_name")
else column_tuple[0],
column_tuple[-1].raw_name
if hasattr(column_tuple[-1], "raw_name")
else column_tuple[-1],
)
)
yield self.build_lineage_request( yield self.build_lineage_request(
source=str(from_table_name), source=str(from_table_name),
db_service_name=db_service_name, db_service_name=db_service_name,