yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-09-26 01:15:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix: dbt multi owner support from manifest (#21233)

Browse Source
This commit is contained in:
Suman Maharana 2025-05-19 12:04:22 +05:30 committed by GitHub
parent 9ec424a3fa
commit 5a3d40f643
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 24 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
ingestion/src/metadata/ingestion/source/database/dbt/metadata.py
View File

@ -150,29 +150,37 @@ class DbtSource(DbtServiceSource):
Returns dbt owner
"""
try:
owner = None
owner_ref = None
dbt_owner = None
if catalog_node:
dbt_owner = catalog_node.metadata.owner
if manifest_node:
dbt_owner = manifest_node.meta.get(DbtCommonEnum.OWNER.value)
if dbt_owner:
owner = self.metadata.get_reference_by_name(
if dbt_owner and isinstance(dbt_owner, str):
owner_ref = self.metadata.get_reference_by_name(
name=dbt_owner, is_owner=True
) or self.metadata.get_reference_by_email(email=dbt_owner)
if owner_ref:
return owner_ref
logger.warning(
"Unable to ingest owner from DBT since no user or"
f" team was found with name {dbt_owner}"
)
if owner:
return owner
# If owner is not found, try to find the owner in OMD using email
owner = self.metadata.get_reference_by_email(email=dbt_owner)
if not owner:
logger.warning(
"Unable to ingest owner from DBT since no user or"
f" team was found with name {dbt_owner}"
)
return owner
elif dbt_owner and isinstance(dbt_owner, list):
owner_list = EntityReferenceList(root=[])
for owner_name in dbt_owner:
owner_ref = self.metadata.get_reference_by_name(
name=owner_name, is_owner=True
) or self.metadata.get_reference_by_email(email=owner_name)
if owner_ref:
owner_list.root.extend(owner_ref.root)
else:
logger.warning(
"Unable to ingest owner from DBT since no user or"
f" team was found with name {owner_name}"
)
if owner_list.root:
return owner_list
except Exception as exc:
logger.debug(traceback.format_exc())
logger.warning(f"Unable to ingest owner from DBT due to: {exc}")