hotfix: fixed column lineage bug with get asset name

bruin-data · Feb 3, 2025 · 7a3ec52 · 7a3ec52
1 parent 271ead7
commit 7a3ec52
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/pipeline/lineage.go b/pkg/pipeline/lineage.go
@@ -191,7 +191,7 @@ func (p *LineageExtractor) processLineageColumns(foundPipeline *Pipeline, asset
 				continue
 			}
 
-			upstreamAsset := foundPipeline.GetAssetByName(upstream.Table)
+			upstreamAsset := foundPipeline.GetAssetByName(strings.ToLower(upstream.Table))
 			if upstreamAsset == nil {
 				if err := p.addColumnToAsset(asset, lineageCol.Name, nil, &Column{
 					Name:   lineageCol.Name,