diff --git a/ingestion/src/metadata/ingestion/source/database/athena/utils.py b/ingestion/src/metadata/ingestion/source/database/athena/utils.py index 66d68d08313..3219cb3bdc5 100644 --- a/ingestion/src/metadata/ingestion/source/database/athena/utils.py +++ b/ingestion/src/metadata/ingestion/source/database/athena/utils.py @@ -173,7 +173,7 @@ def get_columns(self, connection, table_name, schema=None, **kw): for glue_col in glue_columns: col_name = glue_col["Name"] col_type = glue_col["Type"] - col_comment = glue_col.get("Comment", "") + col_comment = glue_col.get("Comment") col_parameters = glue_col.get("Parameters", {}) # Check if this is a non-current Iceberg column diff --git a/ingestion/src/metadata/ingestion/source/database/glue/metadata.py b/ingestion/src/metadata/ingestion/source/database/glue/metadata.py index 0a8c5c5d18f..35b171f0448 100755 --- a/ingestion/src/metadata/ingestion/source/database/glue/metadata.py +++ b/ingestion/src/metadata/ingestion/source/database/glue/metadata.py @@ -406,7 +406,7 @@ class GlueSource(ExternalTableLineageMixin, DatabaseServiceSource): for glue_col in glue_columns: col_name = glue_col["Name"] col_type = glue_col["Type"] - col_comment = glue_col.get("Comment", "") + col_comment = glue_col.get("Comment") col_parameters = glue_col.get("Parameters", {}) # Check if this is a non-current Iceberg column @@ -427,7 +427,7 @@ class GlueSource(ExternalTableLineageMixin, DatabaseServiceSource): for glue_col in partition_keys: col_name = glue_col["Name"] col_type = glue_col["Type"] - col_comment = glue_col.get("Comment", "") + col_comment = glue_col.get("Comment") col_parameters = glue_col.get("Parameters", {}) # Check if this is a non-current Iceberg column