fix(ingest/snowflake): improve warn message (datahub-project#12125)

Co-authored-by: Mayuri Nehate <[email protected]>
sleeperdeep · Dec 17, 2024 · 8d7198b · 8d7198b
1 parent e697985
commit 8d7198b
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/metadata-ingestion/src/datahub/ingestion/source/snowflake/snowflake_lineage_v2.py b/metadata-ingestion/src/datahub/ingestion/source/snowflake/snowflake_lineage_v2.py
@@ -413,9 +413,10 @@ def _process_upstream_lineage_row(
             return UpstreamLineageEdge.parse_obj(db_row)
         except Exception as e:
             self.report.num_upstream_lineage_edge_parsing_failed += 1
+            upstream_tables = db_row.get("UPSTREAM_TABLES")
             self.structured_reporter.warning(
                 "Failed to parse lineage edge",
-                context=db_row.get("DOWNSTREAM_TABLE_NAME") or None,
+                context=f"Upstreams: {upstream_tables} Downstreams: {db_row.get('DOWNSTREAM_TABLE_NAME')}",
                 exc=e,
             )
             return None