From 8d7198b5abe9732a28d4ea930567687760575973 Mon Sep 17 00:00:00 2001 From: Aseem Bansal Date: Fri, 13 Dec 2024 23:09:30 +0530 Subject: [PATCH] fix(ingest/snowflake): improve warn message (#12125) Co-authored-by: Mayuri Nehate <33225191+mayurinehate@users.noreply.github.com> --- .../datahub/ingestion/source/snowflake/snowflake_lineage_v2.py | 3 ++- 1 file changed, 2 insertions(+), 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 index e065e2f34bc66..93d84d8b246e5 100644 --- 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