Skip to content

Commit 4c154e7

Browse files
authored
fix redshift stage when no hashed columns are provided
1 parent cd8e3a8 commit 4c154e7

File tree

1 file changed

+9
-7
lines changed

1 file changed

+9
-7
lines changed

macros/staging/redshift/stage.sql

Lines changed: 9 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -348,13 +348,15 @@ derived_columns AS (
348348
{%- else -%}
349349
{%- set derived_columns_dict = [] -%}
350350
{%- endif -%}
351-
{%- for hash_column_key in hashed_columns.keys() -%}
352-
{%- if hashed_columns[hash_column_key] is mapping -%}
353-
{%- do hashed_columns[hash_column_key].update({'columns': datavault4dbt.get_field_hash_by_datatype(hashed_columns=hashed_columns[hash_column_key]['columns'], all_datatype_columns=all_columns, derived_columns=derived_columns_dict)}) -%}
354-
{%- elif datavault4dbt.is_list(hashed_columns[hash_column_key]) -%}
355-
{%- do hashed_columns.update({hash_column_key: datavault4dbt.get_field_hash_by_datatype(hashed_columns=hashed_columns[hash_column_key], all_datatype_columns=all_columns, derived_columns=derived_columns_dict)}) -%}
356-
{%- endif -%}
357-
{%- endfor -%}
351+
{%- if datavault4dbt.is_something(hashed_columns) %}
352+
{%- for hash_column_key in hashed_columns.keys() -%}
353+
{%- if hashed_columns[hash_column_key] is mapping -%}
354+
{%- do hashed_columns[hash_column_key].update({'columns': datavault4dbt.get_field_hash_by_datatype(hashed_columns=hashed_columns[hash_column_key]['columns'], all_datatype_columns=all_columns, derived_columns=derived_columns_dict)}) -%}
355+
{%- elif datavault4dbt.is_list(hashed_columns[hash_column_key]) -%}
356+
{%- do hashed_columns.update({hash_column_key: datavault4dbt.get_field_hash_by_datatype(hashed_columns=hashed_columns[hash_column_key], all_datatype_columns=all_columns, derived_columns=derived_columns_dict)}) -%}
357+
{%- endif -%}
358+
{%- endfor -%}
359+
{%- endif -%}
358360
{%- endif -%}
359361

360362
{%- if datavault4dbt.is_something(hashed_columns) and hashed_columns is mapping %}

0 commit comments

Comments
 (0)