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

Added debug logs in looker (#19602)

Browse Source
This commit is contained in:
Suman Maharana 2025-01-31 16:45:35 +05:30 committed by SumanMaharana
parent 2a55b81d89
commit bf10eb4231
2 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -496,9 +496,13 @@ class LookerSource(DashboardServiceSource):
try: try:
project_parser = self.parser.get(explore.project_name) project_parser = self.parser.get(explore.project_name)
if project_parser: if project_parser:
return project_parser.parsed_files.get( explore_sql = project_parser.parsed_files.get(
Includes(get_path_from_link(explore.lookml_link)) Includes(get_path_from_link(explore.lookml_link))
) )
logger.debug(
f"Explore SQL for project {explore.project_name}: \n{explore_sql}"
)
return explore_sql
except Exception as err: except Exception as err:
logger.warning(f"Exception getting the model sql: {err}") logger.warning(f"Exception getting the model sql: {err}")
@ -597,6 +601,7 @@ class LookerSource(DashboardServiceSource):
sql_query = view.derived_table.sql sql_query = view.derived_table.sql
if not sql_query: if not sql_query:
return return
logger.debug(f"Processing view [{view.name}] with SQL: \n[{sql_query}]")
for db_service_name in db_service_names or []: for db_service_name in db_service_names or []:
lineage_parser = LineageParser( lineage_parser = LineageParser(
sql_query, sql_query,

3
ingestion/src/metadata/ingestion/source/dashboard/looker/parser.py
View File

@ -181,6 +181,9 @@ class LkmlParser:
Otherwise, return None Otherwise, return None
""" """
if view_name in self._views_cache: if view_name in self._views_cache:
logger.debug(
f"Found view [{view_name}] in cache: \n{self._views_cache[view_name]}"
)
return self._views_cache[view_name] return self._views_cache[view_name]
return None return None