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

Fix column lineage nonetype error (#13432)

Browse Source
This commit is contained in:
Mayur Singal 2023-10-04 17:48:56 +05:30 committed by GitHub
parent 2e49b72ccf
commit 3b640b43b7
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 10 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
ingestion/src/metadata/ingestion/lineage/sql_lineage.py
View File

@ -252,17 +252,17 @@ def _build_table_lineage(
""" """
Prepare the lineage request generator Prepare the lineage request generator
""" """
col_lineage = get_column_lineage(
to_entity=to_entity,
to_table_raw_name=str(to_table_raw_name),
from_entity=from_entity,
from_table_raw_name=str(from_table_raw_name),
column_lineage_map=column_lineage_map,
)
lineage_details = LineageDetails(sqlQuery=query, source=lineage_source)
if col_lineage:
lineage_details.columnsLineage = col_lineage
if from_entity and to_entity: if from_entity and to_entity:
col_lineage = get_column_lineage(
to_entity=to_entity,
to_table_raw_name=str(to_table_raw_name),
from_entity=from_entity,
from_table_raw_name=str(from_table_raw_name),
column_lineage_map=column_lineage_map,
)
lineage_details = LineageDetails(sqlQuery=query, source=lineage_source)
if col_lineage:
lineage_details.columnsLineage = col_lineage
lineage = AddLineageRequest( lineage = AddLineageRequest(
edge=EntitiesEdge( edge=EntitiesEdge(
fromEntity=EntityReference( fromEntity=EntityReference(