diff --git a/ingestion/src/metadata/ingestion/source/database/dbt/metadata.py b/ingestion/src/metadata/ingestion/source/database/dbt/metadata.py index de365accef8..ef5ad1fd558 100644 --- a/ingestion/src/metadata/ingestion/source/database/dbt/metadata.py +++ b/ingestion/src/metadata/ingestion/source/database/dbt/metadata.py @@ -606,19 +606,21 @@ class DbtSource(DbtServiceSource): entity_list=from_es_result, fetch_multiple_entities=False ) if from_entity and to_entity: - yield AddLineageRequest( - edge=EntitiesEdge( - fromEntity=EntityReference( - id=from_entity.id.__root__, - type="table", - ), - toEntity=EntityReference( - id=to_entity.id.__root__, - type="table", - ), - lineageDetails=LineageDetails( - source=LineageSource.DbtLineage - ), + yield Either( + right=AddLineageRequest( + edge=EntitiesEdge( + fromEntity=EntityReference( + id=from_entity.id.__root__, + type="table", + ), + toEntity=EntityReference( + id=to_entity.id.__root__, + type="table", + ), + lineageDetails=LineageDetails( + source=LineageSource.DbtLineage + ), + ) ) )