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

MINOR: Fix 'lr_sqlparser' referenced before assignment (#20823)

Browse Source
This commit is contained in:
Mayur Singal 2025-04-15 13:00:04 +05:30 committed by GitHub
parent 40ab1814c0
commit 3e4b8f5293
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
ingestion/src/metadata/ingestion/lineage/parser.py
View File

@ -453,6 +453,7 @@ class LineageParser:
lr_sqlparser.get_column_lineage() lr_sqlparser.get_column_lineage()
return lr_sqlparser return lr_sqlparser
lr_sqlparser = None
try: try:
lr_sqlparser = get_sqlparser_lineage_runner(query) lr_sqlparser = get_sqlparser_lineage_runner(query)
_ = len(lr_sqlparser.get_column_lineage()) + len( _ = len(lr_sqlparser.get_column_lineage()) + len(
@ -472,7 +473,7 @@ class LineageParser:
except Exception: except Exception:
# if both runner have failed we return the usual one # if both runner have failed we return the usual one
logger.debug(f"Failed to parse query with sqlparse & sqlfluff: {query}") logger.debug(f"Failed to parse query with sqlparse & sqlfluff: {query}")
return lr_sqlfluff if lr_sqlfluff else lr_sqlparser return lr_sqlfluff if lr_sqlfluff else None
self.masked_query = mask_query(self._clean_query, parser=lr_sqlparser) self.masked_query = mask_query(self._clean_query, parser=lr_sqlparser)
logger.debug( logger.debug(