yujunjun/datahub
2
0
Fork 0
mirror of https://github.com/datahub-project/datahub.git synced 2025-11-15 19:03:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

style(ingest/tableau): Rename tableau_constant to c (#9207)

Browse Source
This commit is contained in:
Andrew Sikowitz 2023-11-08 18:17:49 -05:00 committed by GitHub
parent f38c8087bb
commit f73ecfdcbb
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 272 additions and 339 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

597
metadata-ingestion/src/datahub/ingestion/source/tableau.py
View File

File diff suppressed because it is too large Load Diff

14
metadata-ingestion/src/datahub/ingestion/source/tableau_common.py
View File

@ -8,7 +8,7 @@ from pydantic.fields import Field
import datahub.emitter.mce_builder as builder import datahub.emitter.mce_builder as builder
from datahub.configuration.common import ConfigModel from datahub.configuration.common import ConfigModel
from datahub.ingestion.source import tableau_constant as tc from datahub.ingestion.source import tableau_constant as c
from datahub.metadata.com.linkedin.pegasus2avro.dataset import ( from datahub.metadata.com.linkedin.pegasus2avro.dataset import (
DatasetLineageType, DatasetLineageType,
FineGrainedLineage, FineGrainedLineage,
@ -591,12 +591,12 @@ class TableauUpstreamReference:
cls, d: dict, default_schema_map: Optional[Dict[str, str]] = None cls, d: dict, default_schema_map: Optional[Dict[str, str]] = None
) -> "TableauUpstreamReference": ) -> "TableauUpstreamReference":
# Values directly from `table` object from Tableau # Values directly from `table` object from Tableau
database = t_database = d.get(tc.DATABASE, {}).get(tc.NAME) database = t_database = d.get(c.DATABASE, {}).get(c.NAME)
schema = t_schema = d.get(tc.SCHEMA) schema = t_schema = d.get(c.SCHEMA)
table = t_table = d.get(tc.NAME) or "" table = t_table = d.get(c.NAME) or ""
t_full_name = d.get(tc.FULL_NAME) t_full_name = d.get(c.FULL_NAME)
t_connection_type = d[tc.CONNECTION_TYPE] # required to generate urn t_connection_type = d[c.CONNECTION_TYPE] # required to generate urn
t_id = d[tc.ID] t_id = d[c.ID]
parsed_full_name = cls.parse_full_name(t_full_name) parsed_full_name = cls.parse_full_name(t_full_name)
if parsed_full_name and len(parsed_full_name) == 3: if parsed_full_name and len(parsed_full_name) == 3: