switch back to column type

Widen · Apr 24, 2023 · 72ca90d · 72ca90d
1 parent 6e5b1a6
commit 72ca90d
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/tap_mysql/client.py b/tap_mysql/client.py
@@ -22,7 +22,7 @@
         "table_schema",
         "table_name",
         "column_name",
-        "data_type",
+        "column_type",
         "is_nullable",
         "column_key",
     ],
@@ -122,7 +122,7 @@ def create_catalog_entry(
 
             # Initialize columns list
             jsonschema_type: dict = self.to_jsonschema_type(
-                cast(sqlalchemy.types.TypeEngine, col.data_type),
+                cast(sqlalchemy.types.TypeEngine, col.column_type),
             )
             table_schema.append(
                 th.Property(
@@ -197,7 +197,7 @@ def discover_catalog_entries(self) -> list[dict]:
                     table_schema
                     , table_name
                     , column_name
-                    , data_type
+                    , column_type
                     , is_nullable
                     , column_key
                 FROM information_schema.columns