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

MINOR - Report status for tests that blow up (#23326)

Browse Source 
* MINOR - Report status for tests that blow up

* format
This commit is contained in:
Pere Miquel Brull 2025-09-22 16:34:36 +02:00 committed by GitHub
parent d1e60acd2a
commit 49bdf1a112
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
ingestion/src/metadata/data_quality/interface/test_suite_interface.py
View File

@ -27,7 +27,7 @@ from metadata.data_quality.validations.runtime_param_setter.param_setter_factory
) )
from metadata.generated.schema.entity.data.table import Table from metadata.generated.schema.entity.data.table import Table
from metadata.generated.schema.entity.services.databaseService import DatabaseConnection from metadata.generated.schema.entity.services.databaseService import DatabaseConnection
from metadata.generated.schema.tests.basic import TestCaseResult from metadata.generated.schema.tests.basic import TestCaseResult, TestCaseStatus
from metadata.generated.schema.tests.testCase import TestCase from metadata.generated.schema.tests.testCase import TestCase
from metadata.generated.schema.tests.testDefinition import TestDefinition from metadata.generated.schema.tests.testDefinition import TestDefinition
from metadata.ingestion.ometa.ometa_api import OpenMetadata from metadata.ingestion.ometa.ometa_api import OpenMetadata
@ -134,10 +134,16 @@ class TestSuiteInterface(ABC):
try: try:
return validator.run_validation() return validator.run_validation()
except Exception as err: except Exception as err:
logger.error( message = (
f"Error executing {test_case.testDefinition.fullyQualifiedName} - {err}" f"Error executing {test_case.testDefinition.fullyQualifiedName} - {err}"
) )
raise RuntimeError(err) logger.exception(message)
return validator.get_test_case_result_object(
validator.execution_date,
TestCaseStatus.Aborted,
message,
[],
)
def _get_table_config(self): def _get_table_config(self):
"""Get the sampling configuration for the data quality tests""" """Get the sampling configuration for the data quality tests"""