diff --git a/src/dbt_osmosis/core/osmosis.py b/src/dbt_osmosis/core/osmosis.py
index 76e15ab..cadf056 100644
--- a/src/dbt_osmosis/core/osmosis.py
+++ b/src/dbt_osmosis/core/osmosis.py
@@ -396,9 +396,9 @@ def get_columns_meta(self, catalog_key: CatalogKey) -> Dict[str, ColumnMetadata]
                                     continue
                                 columns[self.column_casing(exp.name)] = ColumnMetadata(
                                     name=self.column_casing(exp.name),
-                                    type=c.dtype,
+                                    type=exp.dtype,
                                     index=None,
-                                    comment=getattr(c, "comment", None),
+                                    comment=getattr(exp, "comment", None),
                                 )
                 except Exception as error:
                     logger().info(