fix lint

bruin-data · Jan 31, 2025 · 694c47b · 694c47b
1 parent 234d16f
commit 694c47b
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/pkg/pipeline/lineage.go b/pkg/pipeline/lineage.go
@@ -192,8 +192,8 @@ func (p *LineageExtractor) processLineageColumns(foundPipeline *Pipeline, asset
 			}
 
 			tableSpec := strings.Split(upstream.Table, ".")
-			table_name := tableSpec[len(strings.Split(upstream.Table, "."))-1]
-			upstreamAsset := foundPipeline.GetAssetByName(table_name)
+
+			upstreamAsset := foundPipeline.GetAssetByName(tableSpec[len(tableSpec)-1])
 			if upstreamAsset == nil && upstream.Table != "" {
 				if err := p.addColumnToAsset(asset, lineageCol.Name, nil, &Column{
 					Name:   upstream.Column,
@@ -202,7 +202,7 @@ func (p *LineageExtractor) processLineageColumns(foundPipeline *Pipeline, asset
 					Upstreams: []*UpstreamColumn{
 						{
 							Column: upstream.Column,
-							Table:  strings.ToLower(table_name),
+							Table:  strings.ToLower(tableSpec[len(tableSpec)-1]),
 						},
 					},
 				}); err != nil {