yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-09-21 23:13:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: handle existing dbt test results (#19102)

Browse Source
This commit is contained in:
Teddy 2024-12-18 09:47:58 +01:00 committed by GitHub
parent 4b9948dbfb
commit fec328bb98
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 10 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -62,6 +62,7 @@ from metadata.ingestion.lineage.models import ConnectionTypeDialectMapper
from metadata.ingestion.lineage.sql_lineage import get_lineage_by_query from metadata.ingestion.lineage.sql_lineage import get_lineage_by_query
from metadata.ingestion.models.ometa_classification import OMetaTagAndClassification from metadata.ingestion.models.ometa_classification import OMetaTagAndClassification
from metadata.ingestion.models.table_metadata import ColumnDescription from metadata.ingestion.models.table_metadata import ColumnDescription
from metadata.ingestion.ometa.client import APIError
from metadata.ingestion.ometa.ometa_api import OpenMetadata from metadata.ingestion.ometa.ometa_api import OpenMetadata
from metadata.ingestion.source.database.column_type_parser import ColumnTypeParser from metadata.ingestion.source.database.column_type_parser import ColumnTypeParser
from metadata.ingestion.source.database.database_service import DataModelLink from metadata.ingestion.source.database.database_service import DataModelLink
@ -1071,10 +1072,15 @@ class DbtSource(DbtServiceSource):
else None, else None,
test_case_name=manifest_node.name, test_case_name=manifest_node.name,
) )
try:
self.metadata.add_test_case_results( self.metadata.add_test_case_results(
test_results=test_case_result, test_results=test_case_result,
test_case_fqn=test_case_fqn, test_case_fqn=test_case_fqn,
) )
except APIError as err:
if err.code != 409:
raise APIError(err) from err
except Exception as err: # pylint: disable=broad-except except Exception as err: # pylint: disable=broad-except
logger.debug(traceback.format_exc()) logger.debug(traceback.format_exc())
logger.error( logger.error(