We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent ee82a88 commit 0689c4dCopy full SHA for 0689c4d
metadata-ingestion/src/datahub/ingestion/source/snowflake/snowflake_lineage_v2.py
@@ -413,9 +413,10 @@ def _process_upstream_lineage_row(
413
return UpstreamLineageEdge.parse_obj(db_row)
414
except Exception as e:
415
self.report.num_upstream_lineage_edge_parsing_failed += 1
416
+ upstream_tables = db_row.get("UPSTREAM_TABLES")
417
self.structured_reporter.warning(
418
"Failed to parse lineage edge",
- context=db_row.get("DOWNSTREAM_TABLE_NAME") or None,
419
+ context=f"Upstreams: {upstream_tables} Downstreams: {db_row.get('DOWNSTREAM_TABLE_NAME')}",
420
exc=e,
421
)
422
return None
0 commit comments