Skip to content

Commit

Permalink
Convert qualified table name to f-string
Browse files Browse the repository at this point in the history
  • Loading branch information
ANich committed Mar 19, 2024
1 parent 11a4a68 commit cedeed6
Showing 1 changed file with 2 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -533,11 +533,8 @@ def lineage_via_catalog_lineage_api(
continue

# Convert project table to <project_id>.<dataset_id>.<table_id> format
table = "{}.{}.{}".format(
project_table.project,
project_table.dataset_id,
project_table.table_id,
)
table = f"{project_table.project}.{project_table.dataset_id}.{project_table.table_id}"

logger.info("Creating lineage map for table %s", table)
upstreams = set()
downstream_table = lineage_v1.EntityReference()
Expand Down

0 comments on commit cedeed6

Please sign in to comment.