yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-07-24 17:59:52 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: preserve BQ struct field casing (#21716)

Browse Source
This commit is contained in:
Teddy 2025-06-17 23:58:35 +02:00 committed by GitHub
parent cf288aa5de
commit e4dffd281c
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
ingestion/src/metadata/profiler/interface/sqlalchemy/bigquery/profiler_interface.py
View File

@ -29,7 +29,7 @@ class BigQueryProfilerInterface(SQAProfilerInterface):
from sqlalchemy_bigquery import STRUCT from sqlalchemy_bigquery import STRUCT
columns_list = [] columns_list = []
for key, value in columns.items(): for key, value in columns:
if not isinstance(value, STRUCT): if not isinstance(value, STRUCT):
col = Column(f"{parent}.{key}", value) col = Column(f"{parent}.{key}", value)
# pylint: disable=protected-access # pylint: disable=protected-access
@ -38,7 +38,7 @@ class BigQueryProfilerInterface(SQAProfilerInterface):
columns_list.append(col) columns_list.append(col)
else: else:
col = self._get_struct_columns( col = self._get_struct_columns(
value.__dict__.get("_STRUCT_byname"), f"{parent}.{key}" value.__dict__.get("_STRUCT_fields"), f"{parent}.{key}"
) )
columns_list.extend(col) columns_list.extend(col)
return columns_list return columns_list
@ -53,7 +53,7 @@ class BigQueryProfilerInterface(SQAProfilerInterface):
if isinstance(column.type, STRUCT): if isinstance(column.type, STRUCT):
columns.extend( columns.extend(
self._get_struct_columns( self._get_struct_columns(
column.type.__dict__.get("_STRUCT_byname"), column.name column.type.__dict__.get("_STRUCT_fields"), column.name
) )
) )
else: else: