✨ support for expanding bigquery record columns

.changes/0.11.6.md

@@ -0,0 +1,3 @@
+## 0.11.6 - 2023-03-26
+### Fixed
+* Support for bigquery record columns

CHANGELOG.md

@@ -6,6 +6,13 @@ adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html),
 and is generated by [Changie](https://github.com/miniscruff/changie).
 
 
+## 0.11.6 - 2023-03-26
+### Fixed
+* Support for bigquery record columns
+
+### Changed
+* Backlog of updates [here](https://github.com/z3z1ma/dbt-osmosis/compare/v0.7.6...0.11.5), changelog automations are in progress in tandem with a dedicated documentation website.
+
 ## 0.6.4 - 2022-08-12
 ### Changed
 * --pk is not longer required for diff command as we will use a hash of all columns as a fallback

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "dbt-osmosis"
-version = "0.11.5"
+version = "0.11.6"
 description = "A dbt server and suite of optional developer tools to make developing with dbt delightful."
 authors = ["z3z1ma <[email protected]>"]
 license = "Apache 2.0"

src/dbt_osmosis/core/osmosis.py

@@ -275,7 +275,9 @@ def get_columns(self, node: ManifestNode) -> List[str]:
                 return columns
             try:
                 columns = [
-                    self.column_casing(c.name) for c in self.adapter.get_columns_in_relation(table)
+                    self.column_casing(exp.name)
+                    for c in self.adapter.get_columns_in_relation(table)
+                    for exp in getattr(c, "flatten", lambda: [c])()
                 ]
             except Exception as error:
                 logger().info(
@@ -324,14 +326,18 @@ def bootstrap_sources(self) -> None:
                         "description": "",
                         "columns": [
                             {
-                                "name": self.column_casing(column.name),
-                                "description": getattr(column, "description", ""),
+                                "name": self.column_casing(exp.name),
+                                "description": getattr(
+                                    exp, "description", getattr(c, "description", "")
+                                ),
                             }
-                            for column in self.adapter.get_columns_in_relation(relation)
+                            for c in self.adapter.get_columns_in_relation(relation)
+                            for exp in getattr(c, "flatten", lambda: [c])()
                         ],
                     }
                     for relation in relations
                 ]
+                osmosis_schema_path.parent.mkdir(parents=True, exist_ok=True)
                 with open(osmosis_schema_path, "w") as schema_file:
                     logger().info(
                         ":syringe: Injecting source %s into dbt project",