fix: use string when text is passed (#498)

Co-authored-by: Jeremy Guiselin <jeremy.guiselin@jobteaser.com>
dbt-labs · Nov 10, 2023 · 3d6e488 · 3d6e488
1 parent 673b9a7
commit 3d6e488
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 0 deletions.
diff --git a/dbt/adapters/athena/column.py b/dbt/adapters/athena/column.py
@@ -1,4 +1,5 @@
 from dataclasses import dataclass
+from typing import ClassVar, Dict
 
 from dbt.adapters.athena.relation import TableType
 from dbt.adapters.base.column import Column
@@ -9,6 +10,11 @@
 class AthenaColumn(Column):
     table_type: TableType = TableType.TABLE
 
+    TYPE_LABELS: ClassVar[Dict[str, str]] = {
+        "STRING": "VARCHAR",
+        "TEXT": "VARCHAR",
+    }
+
     def is_iceberg(self) -> bool:
         return self.table_type == TableType.ICEBERG
 

diff --git a/dbt/adapters/athena/impl.py b/dbt/adapters/athena/impl.py
@@ -122,6 +122,7 @@ class AthenaAdapter(SQLAdapter):
     ConnectionManager = AthenaConnectionManager
     Relation = AthenaRelation
     AdapterSpecificConfigs = AthenaConfig
+    Column = AthenaColumn
 
     # There is no such concept as constraints in Athena
     CONSTRAINT_SUPPORT = {