diff --git a/dbt/include/spark/macros/adapters.sql b/dbt/include/spark/macros/adapters.sql index 6abfc3677..5853d4a33 100644 --- a/dbt/include/spark/macros/adapters.sql +++ b/dbt/include/spark/macros/adapters.sql @@ -278,7 +278,7 @@ {% endmacro %} {% macro spark__alter_column_comment(relation, column_dict) %} - {% if config.get('file_format', validator=validation.any[basestring]) in ['delta', 'hudi'] %} + {% if config.get('file_format', validator=validation.any[basestring]) in ['delta', 'hudi', 'iceberg'] %} {% for column_name in column_dict %} {% set comment = column_dict[column_name]['description'] %} {% set escaped_comment = comment | replace('\'', '\\\'') %}