fix: ensure records and structs are flattened

.changes/1.1.11.md

@@ -0,0 +1,4 @@
+## 1.1.11 - 2025-01-30
+### Fixed
+* Ensure records and structs are flattened
+* Leverage data_type prop on adapter column if mode is present

CHANGELOG.md

@@ -6,6 +6,11 @@ adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html),
 and is generated by [Changie](https://github.com/miniscruff/changie).
 
 
+## 1.1.11 - 2025-01-30
+### Fixed
+* Ensure records and structs are flattened
+* Leverage data_type prop on adapter column if mode is present
+
 ## 1.1.10 - 2025-01-29
 ### Added
 * Match on corresponding node when passing yaml file path(s) in positional selectors ie like with pre-commit

pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "hatchling.build"
 
 [project]
 name = "dbt-osmosis"
-version = "1.1.10"
+version = "1.1.11"
 description = "A dbt utility for managing YAML to make developing with dbt more delightful."
 readme = "README.md"
 license = { text = "Apache-2.0" }

src/dbt_osmosis/core/osmosis.py

@@ -822,6 +822,8 @@ def _maybe_use_precise_dtype(
     if (col.is_numeric() and use_num_prec) or (col.is_string() and use_chr_prec):
         logger.debug(":ruler: Using precise data type => %s", col.data_type)
         return col.data_type
+    if hasattr(col, "mode"):
+        return col.data_type
     return col.dtype
 
 
@@ -859,12 +861,14 @@ def process_column(col: BaseColumn | ColumnMetadata):
             )
             return
         normalized = normalize_column_name(col.name, context.project.runtime_cfg.credentials.type)
-        if not isinstance(col, ColumnMetadata):
+        if isinstance(col, ColumnMetadata):
+            col_meta = col
+        else:
             dtype = _maybe_use_precise_dtype(col, context.settings)
-            col = ColumnMetadata(
+            col_meta = ColumnMetadata(
                 name=normalized, type=dtype, index=offset, comment=getattr(col, "comment", None)
             )
-        normalized_cols[normalized] = col
+        normalized_cols[normalized] = col_meta
         offset += 1
         if hasattr(col, "flatten"):
             for struct_field in t.cast(Iterable[BaseColumn], getattr(col, "flatten")()):