yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-12-03 19:16:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

Minor: improved dbt debug logs (#23509)

Browse Source 
(cherry picked from commit 79fde4ab028228e92e1ef648974584cecc244222)
This commit is contained in:
Suman Maharana 2025-09-23 19:52:58 +05:30 committed by OpenMetadata Release Bot
parent 920ab734de
commit e2a5fa1404
1 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -15,7 +15,7 @@ DBT source methods.
import traceback import traceback
from copy import deepcopy from copy import deepcopy
from datetime import datetime 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.lineage.addLineage import AddLineageRequest
from metadata.generated.schema.api.tests.createTestCase import CreateTestCaseRequest from metadata.generated.schema.api.tests.createTestCase import CreateTestCaseRequest
@ -444,7 +444,7 @@ class DbtSource(DbtServiceSource):
fetch_multiple_entities=True, fetch_multiple_entities=True,
) )
logger.debug( 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 ( return (
next(iter(filter(None, table_entities)), None) next(iter(filter(None, table_entities)), None)
@ -455,6 +455,10 @@ class DbtSource(DbtServiceSource):
try: try:
table_entity = search_table(table_fqn) table_entity = search_table(table_fqn)
if table_entity: if table_entity:
logger.debug(
f"Using Table Entity: {table_entity.fullyQualifiedName.root}"
f"with id {table_entity.id}"
)
return table_entity return table_entity
if self.source_config.searchAcrossDatabases: if self.source_config.searchAcrossDatabases:
@ -620,7 +624,8 @@ class DbtSource(DbtServiceSource):
if table_entity := self._get_table_entity(table_fqn=table_fqn): if table_entity := self._get_table_entity(table_fqn=table_fqn):
logger.debug( 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( data_model_link = DataModelLink(
table_entity=table_entity, table_entity=table_entity,