Merge pull request #44 from flexanalytics/columns-model-check

check if table exists before uploading columns
flexanalytics · Oct 1, 2024 · 8a5ad7d · 8a5ad7d
2 parents 4c2dd31 + 58e48ad
commit 8a5ad7d
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/macros/upload_columns.sql b/macros/upload_columns.sql
@@ -100,8 +100,12 @@
                 {% do lowerCols.update({k.lower(): v}) %}
             {% endfor %}
 
-            {% set relation = dbt_observability.get_relation( model.name ) %}
-            {%- set columns = adapter.get_columns_in_relation(relation) -%}
+            {%- set relation = adapter.get_relation(database=model.database, schema=model.schema, identifier=model.name) -%}
+            {% set table_exists=relation is not none %}
+
+            {% if table_exists %}
+                {%- set columns = adapter.get_columns_in_relation(relation) -%}
+            {% endif %}
 
             {% set statsType = dbt_observability.get_observability_value('column_stats_type', model) %}