yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-11-09 15:32:25 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fixed lineage issue for double schema name (#4274)

Browse Source
This commit is contained in:
Onkar Ravgan 2022-04-20 16:33:36 +05:30 committed by GitHub
parent e64bed10b4
commit 093a146724
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
ingestion/src/metadata/ingestion/ometa/mixins/lineage_mixin.py
View File

@ -245,3 +245,4 @@ class OMetaLineageMixin(Generic[T]):
except Exception as err: except Exception as err:
logger.debug(str(err)) logger.debug(str(err))
logger.error(f"Ingesting lineage failed") logger.error(f"Ingesting lineage failed")
return False

5
ingestion/src/metadata/ingestion/sink/metadata_rest.py
View File

@ -538,9 +538,12 @@ class MetadataRestSink(Sink[Entity]):
try: try:
parser = Parser(db_schema_and_table.table.viewDefinition.__root__) parser = Parser(db_schema_and_table.table.viewDefinition.__root__)
to_table_name = db_schema_and_table.table.name.__root__ to_table_name = db_schema_and_table.table.name.__root__
for from_table_name in parser.tables: for from_table_name in parser.tables:
if "." not in from_table_name:
from_table_name = f"{db_schema.name.__root__}.{from_table_name}"
self.metadata._create_lineage_by_table_name( self.metadata._create_lineage_by_table_name(
f"{db_schema.name.__root__}.{from_table_name}", from_table_name,
f"{db_schema.name.__root__}.{to_table_name}", f"{db_schema.name.__root__}.{to_table_name}",
db.service.name, db.service.name,
db_schema_and_table.database.name.__root__, db_schema_and_table.database.name.__root__,