yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-10-31 10:39:30 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix #5167: Fix Tag Category Creating Issue (#5168)

Browse Source
This commit is contained in:
Mayur Singal 2022-05-26 18:45:12 +05:30 committed by GitHub
parent 0edb13fd2c
commit cf268c9cdd
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 12 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
ingestion/src/metadata/ingestion/source/database/bigquery.py
View File

@ -94,20 +94,6 @@ class BigquerySource(CommonDbSourceService):
) )
self.temp_credentials = None self.temp_credentials = None
# and "policy_tags" in column and column["policy_tags"]
def prepare(self):
try:
if self.connection_config.enablePolicyTagImport:
self.metadata.create_tag_category(
CreateTagCategoryRequest(
name=self.connection_config.tagCategoryName,
description="",
categoryType="Classification",
)
)
except Exception as err:
logger.error(err)
@classmethod @classmethod
def create(cls, config_dict, metadata_config: OpenMetadataConnection): def create(cls, config_dict, metadata_config: OpenMetadataConnection):
config: WorkflowSource = WorkflowSource.parse_obj(config_dict) config: WorkflowSource = WorkflowSource.parse_obj(config_dict)
@ -131,6 +117,18 @@ class BigquerySource(CommonDbSourceService):
def prepare(self): def prepare(self):
self.service_connection.database = self.service_connection.projectId self.service_connection.database = self.service_connection.projectId
# and "policy_tags" in column and column["policy_tags"]
try:
if self.source_config.includeTags:
self.metadata.create_tag_category(
CreateTagCategoryRequest(
name=self.connection_config.tagCategoryName,
description="",
categoryType="Classification",
)
)
except Exception as err:
logger.error(err)
return super().prepare() return super().prepare()
def fetch_sample_data(self, schema: str, table: str) -> Optional[TableData]: def fetch_sample_data(self, schema: str, table: str) -> Optional[TableData]: