diff --git a/ingestion/src/metadata/ingestion/lineage/sql_lineage.py b/ingestion/src/metadata/ingestion/lineage/sql_lineage.py index 36c152b8770..78bd64054d4 100644 --- a/ingestion/src/metadata/ingestion/lineage/sql_lineage.py +++ b/ingestion/src/metadata/ingestion/lineage/sql_lineage.py @@ -246,9 +246,9 @@ def _build_table_lineage( from_table_raw_name=str(from_table_raw_name), column_lineage_map=column_lineage_map, ) - lineage_details = None + lineage_details = LineageDetails(sqlQuery=query) if col_lineage: - lineage_details = LineageDetails(sqlQuery=query, columnsLineage=col_lineage) + lineage_details.columnsLineage = col_lineage if from_entity and to_entity: lineage = AddLineageRequest( edge=EntitiesEdge(