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

Fixes 13343: Fix Superset table name issue (#14714)

Browse Source
This commit is contained in:
Ayush Shah 2024-01-15 18:19:27 +05:30 committed by GitHub
parent 98eae7154a
commit 709fa7415f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
ingestion/src/metadata/ingestion/source/dashboard/superset/db_source.py
View File

@ -86,8 +86,9 @@ class SupersetDBSource(SupersetSourceMixin):
def get_column_list(self, table_name: str) -> Iterable[FetchChart]: def get_column_list(self, table_name: str) -> Iterable[FetchChart]:
try: try:
if table_name: if table_name:
sql_query = sql.text(FETCH_COLUMN.format(table_name=table_name.lower())) col_list = self.engine.execute(
col_list = self.engine.execute(sql_query) sql.text(FETCH_COLUMN), table_name=table_name.lower()
)
return [FetchColumn(**col) for col in col_list] return [FetchColumn(**col) for col in col_list]
except Exception as err: except Exception as err:
logger.debug(traceback.format_exc()) logger.debug(traceback.format_exc())

2
ingestion/src/metadata/ingestion/source/dashboard/superset/queries.py
View File

@ -85,5 +85,5 @@ inner join
on on
t.id=tc.table_id t.id=tc.table_id
where where
table_name= '{table_name}' table_name= %(table_name)s
""" """