Skip to content

Commit

Permalink
Update sql_common.py
Browse files Browse the repository at this point in the history
  • Loading branch information
acrylJonny committed Dec 2, 2024
1 parent fb1409d commit e2f6b26
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -982,8 +982,8 @@ def simplify_field_path(field_path):

if schema_fields and upstream_schema_metadata:
fine_grained_lineages: List[FineGrainedLineage] = []
for field in schema_fields:
field_path_v1 = simplify_field_path(field.fieldPath)
for schema_field in schema_fields:
field_path_v1 = simplify_field_path(schema_field.fieldPath)
matching_upstream_field = next(
(
f
Expand Down

0 comments on commit e2f6b26

Please sign in to comment.