Skip to content

Commit

Permalink
Update liniting
Browse files Browse the repository at this point in the history
  • Loading branch information
isura-nimalasiri committed Jul 10, 2024
1 parent 28b4df7 commit 2e988f2
Showing 1 changed file with 10 additions and 4 deletions.
14 changes: 10 additions & 4 deletions metadata-ingestion/src/datahub/ingestion/source/tableau.py
Original file line number Diff line number Diff line change
Expand Up @@ -145,7 +145,7 @@
SubTypesClass,
ViewPropertiesClass,
SchemaMetadataClass,
EditableSchemaMetadataClass
EditableSchemaMetadataClass,
)
from datahub.sql_parsing.sql_parsing_result_utils import (
transform_parsing_result_to_in_tables_schemas,
Expand Down Expand Up @@ -2253,10 +2253,16 @@ def emit_table(
)
if schema_metadata is not None:
# Check if table already has schema metadata
current_schema_aspect = self.ctx.graph.get_aspect(entity_urn=database_table.urn, aspect_type=SchemaMetadataClass)
current_editable_schema_aspect = self.ctx.graph.get_aspect(entity_urn=database_table.urn, aspect_type=EditableSchemaMetadataClass)
current_schema_aspect = self.ctx.graph.get_aspect(
entity_urn=database_table.urn, aspect_type=SchemaMetadataClass
)
current_editable_schema_aspect = self.ctx.graph.get_aspect(
entity_urn=database_table.urn, aspect_type=EditableSchemaMetadataClass
)
if current_schema_aspect or current_editable_schema_aspect:
logger.debug(f"Table {database_table.urn} already has schema metadata, skipping")
logger.debug(
f"Table {database_table.urn} already has schema metadata, skipping"
)
else:
dataset_snapshot.aspects.append(schema_metadata)

Expand Down

0 comments on commit 2e988f2

Please sign in to comment.