yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2026-01-07 13:07:22 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix:minor changes in atlas (#9418)

Browse Source
This commit is contained in:
NiharDoshi99 2022-12-20 20:44:57 +05:30 committed by GitHub
parent 62091c35d0
commit c72938085d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 20 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

37
ingestion/src/metadata/ingestion/source/metadata/atlas.py
View File

@ -266,30 +266,33 @@ class AtlasSource(Source):
entity=Table, fqn=table_fqn
)
if tbl_attrs.get("description", None) and table_object:
self.metadata.patch_description(
entity_id=table_object.id,
entity=Table,
description=tbl_attrs["description"],
force=True,
if table_object:
if tbl_attrs.get("description", None):
self.metadata.patch_description(
entity_id=table_object.id,
entity=Table,
description=tbl_attrs["description"],
force=True,
)
tag_fqn = fqn.build(
self.metadata,
entity_type=Tag,
tag_category_name=ATLAS_TAG_CATEGORY,
tag_name=ATLAS_TABLE_TAG,
)
tag_fqn = fqn.build(
self.metadata,
entity_type=Tag,
tag_category_name=ATLAS_TAG_CATEGORY,
tag_name=ATLAS_TABLE_TAG,
)
self.metadata.patch_tag(
entity=Table, entity_id=table_object.id, tag_fqn=tag_fqn
)
self.metadata.patch_tag(
entity=Table, entity_id=table_object.id, tag_fqn=tag_fqn
)
yield from self.ingest_lineage(tbl_entity["guid"], name)
except Exception as exc:
logger.debug(traceback.format_exc())
logger.warning(f"Failed to parse {table_entity}: {exc}")
logger.warning(
f"Failed to parse for database : {db_entity} - table {table}: {exc}"
)
def get_tags(self):
tags = [