From 5d4f4a819f9102cb1961e8afc7bbf44f2b9d6b2c Mon Sep 17 00:00:00 2001
From: Mayur Singal <39544459+ulixius9@users.noreply.github.com>
Date: Thu, 10 Nov 2022 12:55:23 +0530
Subject: [PATCH] Fix #8600: Add SQL query in lineage (#8603)

---
 ingestion/src/metadata/ingestion/lineage/sql_lineage.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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(