From 5c8a0642faa153704aa3b44570d5df51a5c5abb7 Mon Sep 17 00:00:00 2001 From: Suman Maharana Date: Thu, 15 May 2025 17:49:47 +0530 Subject: [PATCH] Minor: Add sql query for dbt lineage with nodes (#21214) (cherry picked from commit 2864e0f09d188b5a382dd1d5153536688b7a9e36) --- .../src/metadata/ingestion/source/database/dbt/metadata.py | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/ingestion/src/metadata/ingestion/source/database/dbt/metadata.py b/ingestion/src/metadata/ingestion/source/database/dbt/metadata.py index b0299de842f..41b215a5821 100644 --- a/ingestion/src/metadata/ingestion/source/database/dbt/metadata.py +++ b/ingestion/src/metadata/ingestion/source/database/dbt/metadata.py @@ -741,7 +741,12 @@ class DbtSource(DbtServiceSource): type="table", ), lineageDetails=LineageDetails( - source=LineageSource.DbtLineage + source=LineageSource.DbtLineage, + sqlQuery=SqlQuery( + data_model_link.datamodel.sql.root + ) + if data_model_link.datamodel.sql + else None, ), ) )