feat(dbt): add dagster dbt package

python_modules/libraries/dagster-dbt/packages/dagster/.gitignore

@@ -0,0 +1,3 @@
+target/
+dbt_packages/
+logs/

python_modules/libraries/dagster-dbt/packages/dagster/dbt_project.yml

@@ -0,0 +1,9 @@
+name: "dagster"
+version: "0.0.1"
+config-version: 2
+
+require-dbt-version: [">=1.5.0", "<2.0.0"]
+
+macro-paths: ["macros"]
+
+clean-targets: ["target", "dbt_packages"]

python_modules/libraries/dagster-dbt/packages/dagster/macros/dagster__log_columns_in_relation.sql

@@ -0,0 +1,11 @@
+{% macro dagster__log_columns_in_relation() %}
+    {%- set columns = adapter.get_columns_in_relation(this) -%}
+    {%- set table_schema = {} -%}
+
+    {% for column in columns %}
+        {%- set serializable_column = {column.name: {'data_type': column.data_type}} -%}
+        {%- set _ = table_schema.update(serializable_column) -%}
+    {% endfor %}
+
+    {% do log(tojson(table_schema), info=true) %}
+{% endmacro %}