{% set source = sources[0] %}
{% set src_node = source.dependencies[0].node %}
{% set forecast_name = 'FORECAST_' ~ src_node.name %}


{{ stage('Create Forecast Table') }}


CREATE OR REPLACE TABLE {{ this }}
(
    {% for col in source.columns  %}
        "{{ col.name }}" 
        {%- if col.name == config.tscol.name %} TIMESTAMP 
        {%- elif col.name == config.tgtcol.name %} FLOAT 
        {%- else %} {{ col.dataType }}
        {%- endif %}
        {%- if col.description | length > 0 %} COMMENT '{{ col.description | escape }}'{%- endif %}
        {%- if not loop.last -%}, {% endif %}
    {% endfor %}
)
{%- if node.description | length > 0 %} COMMENT = '{{ node.description | escape }}'{% endif %}