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

Fix #5619: Fix Multiple Source Column Level Lineage (#5620)

Browse Source
This commit is contained in:
Mayur Singal 2022-06-27 16:38:46 +05:30 committed by GitHub
parent 338d1efe40
commit 369f8643d1
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 14 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
ingestion/src/metadata/utils/sql_lineage.py
View File

@ -233,21 +233,22 @@ def populate_column_lineage_map(raw_column_lineage):
if not raw_column_lineage or len(raw_column_lineage[0]) != 2:
return lineage_map
for source, target in raw_column_lineage:
if lineage_map.get(str(target.parent)):
ele = lineage_map.get(str(target.parent))
if ele.get(str(source.parent)):
ele[str(source.parent)].append(
(
target.raw_name,
source.raw_name,
for parent in source._parent:
if lineage_map.get(str(target.parent)):
ele = lineage_map.get(str(target.parent))
if ele.get(str(parent)):
ele[str(parent)].append(
(
target.raw_name,
source.raw_name,
)
)
)
else:
ele[str(parent)] = [(target.raw_name, source.raw_name)]
else:
ele[str(source.parent)] = [(target.raw_name, source.raw_name)]
else:
lineage_map[str(target.parent)] = {
str(source.parent): [(target.raw_name, source.raw_name)]
}
lineage_map[str(target.parent)] = {
str(parent): [(target.raw_name, source.raw_name)]
}
return lineage_map