From e2a5fa14047513f5f3dcf962b3e58a8b7869ebdd Mon Sep 17 00:00:00 2001 From: Suman Maharana Date: Tue, 23 Sep 2025 19:52:58 +0530 Subject: [PATCH] Minor: improved dbt debug logs (#23509) (cherry picked from commit 79fde4ab028228e92e1ef648974584cecc244222) --- .../ingestion/source/database/dbt/metadata.py | 11 ++++++++--- 1 file changed, 8 insertions(+), 3 deletions(-) diff --git a/ingestion/src/metadata/ingestion/source/database/dbt/metadata.py b/ingestion/src/metadata/ingestion/source/database/dbt/metadata.py index e9ceed3e49f..6737d196e11 100644 --- a/ingestion/src/metadata/ingestion/source/database/dbt/metadata.py +++ b/ingestion/src/metadata/ingestion/source/database/dbt/metadata.py @@ -15,7 +15,7 @@ DBT source methods. import traceback from copy import deepcopy from datetime import datetime -from typing import Any, Iterable, List, Optional +from typing import Any, Iterable, List, Optional, Union from metadata.generated.schema.api.lineage.addLineage import AddLineageRequest from metadata.generated.schema.api.tests.createTestCase import CreateTestCaseRequest @@ -444,7 +444,7 @@ class DbtSource(DbtServiceSource): fetch_multiple_entities=True, ) logger.debug( - f"Found table entities from {fqn_search_string}: {table_entities}" + f"Found table entities from {fqn_search_string}: {len(table_entities)} entities" ) return ( next(iter(filter(None, table_entities)), None) @@ -455,6 +455,10 @@ class DbtSource(DbtServiceSource): try: table_entity = search_table(table_fqn) if table_entity: + logger.debug( + f"Using Table Entity: {table_entity.fullyQualifiedName.root}" + f"with id {table_entity.id}" + ) return table_entity if self.source_config.searchAcrossDatabases: @@ -620,7 +624,8 @@ class DbtSource(DbtServiceSource): if table_entity := self._get_table_entity(table_fqn=table_fqn): logger.debug( - f"Using Table Entity for datamodel: {table_entity}" + f"Using Table Entity for datamodel: {table_entity.fullyQualifiedName.root}" + f"with id {table_entity.id}" ) data_model_link = DataModelLink( table_entity=table_entity,