diff --git a/ingestion/src/metadata/ingestion/source/database/dbt/metadata.py b/ingestion/src/metadata/ingestion/source/database/dbt/metadata.py index 242a5bbf392..8178c92a968 100644 --- a/ingestion/src/metadata/ingestion/source/database/dbt/metadata.py +++ b/ingestion/src/metadata/ingestion/source/database/dbt/metadata.py @@ -156,6 +156,13 @@ class DbtSource(DbtServiceSource): owner = self.metadata.get_reference_by_name( name=dbt_owner, is_owner=True ) + + 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(name=dbt_owner) + if not owner: logger.warning( "Unable to ingest owner from DBT since no user or"