From 0f25c539f6deef506b2bde500144143f938b0f64 Mon Sep 17 00:00:00 2001 From: Jonny Dixon Date: Mon, 2 Dec 2024 14:47:26 +0000 Subject: [PATCH] Update sql_common.py --- .../src/datahub/ingestion/source/sql/sql_common.py | 12 +++++++----- 1 file changed, 7 insertions(+), 5 deletions(-) diff --git a/metadata-ingestion/src/datahub/ingestion/source/sql/sql_common.py b/metadata-ingestion/src/datahub/ingestion/source/sql/sql_common.py index b4533270d68cd9..db859af6627046 100644 --- a/metadata-ingestion/src/datahub/ingestion/source/sql/sql_common.py +++ b/metadata-ingestion/src/datahub/ingestion/source/sql/sql_common.py @@ -786,11 +786,13 @@ def _process_table( entityUrn=dataset_snapshot.urn, aspect=UpstreamLineage( upstreams=[external_upstream_table], - fineGrainedLineages=self.get_fine_grained_lineages( - dataset_urn=dataset_snapshot.urn, - upstream_dataset_urn=location_urn, - schema_fields=schema_fields, - ), + fineGrainedLineages=( + self.get_fine_grained_lineages( + dataset_urn=dataset_snapshot.urn, + upstream_dataset_urn=location_urn, + schema_fields=schema_fields, + ), + ) if self.ctx.graph else None ), ).as_workunit()