yujunjun/datahub
2
0
Fork 0
mirror of https://github.com/datahub-project/datahub.git synced 2025-12-01 21:27:15 +00:00
Code Issues Packages Projects Releases Wiki Activity

Update metadata-ingestion/src/datahub/ingestion/source/sql/athena.py

Browse Source 
Co-authored-by: Sergio Gómez Villamor <sgomezvillamor@gmail.com>
This commit is contained in:
Tamas Nemeth 2025-05-27 18:25:02 +02:00
parent f1b70c4030
commit 58e88dbe40
1 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
metadata-ingestion/src/datahub/ingestion/source/sql/athena.py
View File

@ -582,9 +582,7 @@ class AthenaSource(SQLAlchemySource):
rows = res.fetchall()
# Concatenate all rows into a single string with newlines
create_table_statement = ""
for row in rows:
create_table_statement += row[0] + "\n" # Add a newline after each row
create_table_statement = "\n".join(row[0] for row in rows)
try:
athena_table_info = AthenaPropertiesExtractor.get_table_properties(