yujunjun/datahub
2
0
Fork 0
mirror of https://github.com/datahub-project/datahub.git synced 2025-09-17 21:20:32 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(ingest): change LookMLSource._get_upsteam_lineage() to _get_upstream_lineage() (#2888)

Browse Source
This commit is contained in:
James Lamb 2021-07-16 14:14:13 -05:00 committed by GitHub
parent e075a0a004
commit caaf7107b8
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
metadata-ingestion/src/datahub/ingestion/source/lookml.py
View File

@ -398,7 +398,7 @@ class LookMLSource(Source):
f"Could not find a platform for looker view with connection: {connection}" 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 = [] upstreams = []
for sql_table_name in looker_view.sql_table_names: for sql_table_name in looker_view.sql_table_names:
upstream = UpstreamClass( upstream = UpstreamClass(
@ -499,7 +499,7 @@ class LookMLSource(Source):
aspects=[], # we append to this list later on aspects=[], # we append to this list later on
) )
dataset_snapshot.aspects.append(Status(removed=False)) 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)) dataset_snapshot.aspects.append(self._get_schema(looker_view))
mce = MetadataChangeEvent(proposedSnapshot=dataset_snapshot) mce = MetadataChangeEvent(proposedSnapshot=dataset_snapshot)