From caaf7107b8576feae9eca10e8ba16e5ca673ebfa Mon Sep 17 00:00:00 2001 From: James Lamb Date: Fri, 16 Jul 2021 14:14:13 -0500 Subject: [PATCH] fix(ingest): change LookMLSource._get_upsteam_lineage() to _get_upstream_lineage() (#2888) --- metadata-ingestion/src/datahub/ingestion/source/lookml.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/metadata-ingestion/src/datahub/ingestion/source/lookml.py b/metadata-ingestion/src/datahub/ingestion/source/lookml.py index 336b858dda..b0c1bb604a 100644 --- a/metadata-ingestion/src/datahub/ingestion/source/lookml.py +++ b/metadata-ingestion/src/datahub/ingestion/source/lookml.py @@ -398,7 +398,7 @@ class LookMLSource(Source): f"Could not find a platform for looker view with connection: {connection}" ) - def _get_upsteam_lineage(self, looker_view: LookerView) -> UpstreamLineage: + def _get_upstream_lineage(self, looker_view: LookerView) -> UpstreamLineage: upstreams = [] for sql_table_name in looker_view.sql_table_names: upstream = UpstreamClass( @@ -499,7 +499,7 @@ class LookMLSource(Source): aspects=[], # we append to this list later on ) dataset_snapshot.aspects.append(Status(removed=False)) - dataset_snapshot.aspects.append(self._get_upsteam_lineage(looker_view)) + dataset_snapshot.aspects.append(self._get_upstream_lineage(looker_view)) dataset_snapshot.aspects.append(self._get_schema(looker_view)) mce = MetadataChangeEvent(proposedSnapshot=dataset_snapshot)