{% macro glue__reset_csv_table(model, full_refresh, old_relation, agate_table) %} {% set sql = create_csv_table(model, agate_table) %} {{ return(sql) }} {% endmacro %} {% materialization seed, adapter='glue' %} {%- set identifier = model['alias'] -%} {%- set old_relation = adapter.get_relation(database=database, schema=schema, identifier=identifier) -%} {%- set target_relation = api.Relation.create(database=database, schema=schema, identifier=identifier, type='table') -%} {%- set agate_table = load_agate_table() -%} {%- do store_result('agate_table', response='OK', agate_table=agate_table) -%} {{ run_hooks(pre_hooks, inside_transaction=False) }} -- `BEGIN` happens here: {{ run_hooks(pre_hooks, inside_transaction=True) }} -- build model {% set create_table_sql = reset_csv_table(model, full_refresh_mode, old_relation, agate_table) %} {% set status = 'CREATE' %} {% set num_rows = (agate_table.rows | length) %} {% set sql = load_csv_rows(model, agate_table) %} {% call noop_statement('main', status ~ ' ' ~ num_rows) %} {{ create_table_sql }} -- dbt seed -- {{ sql }} {% endcall %} {{ run_hooks(post_hooks, inside_transaction=True) }} -- `COMMIT` happens here {{ adapter.commit() }} {{ run_hooks(post_hooks, inside_transaction=False) }} {{ return({'relations': [target_relation]}) }} {% endmaterialization %}