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

MINOR: Fix issue with SQLAlchemy types not being correctly mapped to OM Type on the profiler (#16122)

Browse Source 
* Fix issue with SQLAlchemy types not being correctly mapped to OM Types on the profiler

* Fix checkstyle
This commit is contained in:
IceS2 2024-05-03 17:05:52 +02:00 committed by GitHub
parent 215a274bd0
commit 795879d776
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
ingestion/src/metadata/profiler/processor/metric_filter.py
View File

@ -168,7 +168,9 @@ class MetricFilter:
if not isinstance(column, SQALikeColumn): if not isinstance(column, SQALikeColumn):
mapper = converter_registry[service_type] mapper = converter_registry[service_type]
sqa_to_om_types = mapper.map_sqa_to_om_types() sqa_to_om_types = mapper.map_sqa_to_om_types()
om_data_types: Optional[Set] = sqa_to_om_types.get(column.type, None) om_data_types: Optional[Set] = sqa_to_om_types.get(
column.type.__class__, None
)
else: else:
om_data_types = {column.type} om_data_types = {column.type}

4
ingestion/tests/integration/profiler/test_sqa_profiler.py
View File

@ -112,7 +112,7 @@ class TestSQAProfiler(TestCase):
tables: List[Table] = self.metadata.list_all_entities(Table) tables: List[Table] = self.metadata.list_all_entities(Table)
for table in tables: for table in tables:
if table.name != "users": if table.name.__root__ != "users":
continue continue
table = self.metadata.get_latest_table_profile(table.fullyQualifiedName) table = self.metadata.get_latest_table_profile(table.fullyQualifiedName)
columns = table.columns columns = table.columns
@ -162,7 +162,7 @@ class TestSQAProfiler(TestCase):
tables: List[Table] = self.metadata.list_all_entities(Table) tables: List[Table] = self.metadata.list_all_entities(Table)
for table in tables: for table in tables:
if table.name != "users": if table.name.__root__ != "users":
continue continue
table = self.metadata.get_latest_table_profile(table.fullyQualifiedName) table = self.metadata.get_latest_table_profile(table.fullyQualifiedName)
columns = table.columns columns = table.columns