File tree Expand file tree Collapse file tree 2 files changed +9
-4
lines changed
dbt_adbs_test_project/snapshots
dbt/include/oracle/macros/materializations/snapshot Expand file tree Collapse file tree 2 files changed +9
-4
lines changed Original file line number Diff line number Diff line change 4343
4444{% macro oracle__snapshot_staging_table(strategy, source_sql, target_relation) - %}
4545
46- {% set columns = config .get (' snapshot_table_column_names ' ) or get_snapshot_table_column_names() %}
46+ {% set columns = config .get (' snapshot_meta_column_names ' ) or get_snapshot_table_column_names() %}
4747 {% if strategy .hard_deletes == ' new_record' %}
4848 {% set new_scd_id = snapshot_hash_arguments([columns .dbt_scd_id , snapshot_get_time()]) %}
4949 {% endif %}
212212
213213
214214{% macro oracle__build_snapshot_table(strategy, sql) %}
215- {% set columns = config .get (' snapshot_table_column_names ' ) or get_snapshot_table_column_names() %}
215+ {% set columns = config .get (' snapshot_meta_column_names ' ) or get_snapshot_table_column_names() %}
216216
217217 select sbq.* ,
218218 {{ strategy .scd_id }} as {{ columns .dbt_scd_id }},
301301
302302 {% else %}
303303
304- {% set columns = config .get (" snapshot_table_column_names " ) or get_snapshot_table_column_names() %}
304+ {% set columns = config .get (" snapshot_meta_column_names " ) or get_snapshot_table_column_names() %}
305305
306306 {{ adapter .assert_valid_snapshot_target_given_strategy (target_relation, columns, strategy) }}
307307
Original file line number Diff line number Diff line change 1818 strategy= ' check' ,
1919 unique_key= ' promo_id' ,
2020 check_cols= ' all' ,
21- hard_deletes= ' invalidate'
21+ hard_deletes= ' invalidate' ,
22+ snapshot_meta_column_names= {
23+ " dbt_valid_from" : " promo_valid_from" ,
24+ " dbt_valid_to" : " promo_valid_to" ,
25+ " dbt_scd_id" : " dbt_scd_id"
26+ }
2227 )
2328 }}
2429 select * from {{ ref(' promotion_costs' ) }}
You can’t perform that action at this time.
0 commit comments