dispatch-ify ALL THE MACROS!

integration_tests/dbt_project.yml

@@ -19,6 +19,9 @@ clean-targets:         # directories to be removed by `dbt clean`
     - "target"
     - "dbt_modules"
 
+vars:
+  dbt_utils_dispatch_list: ['dbt_utils']
+
 seeds:
 
   +quote_columns: false

macros/datetime/date_spine.sql

@@ -1,5 +1,8 @@
 {% macro get_intervals_between(start_date, end_date, datepart) -%}
+    {{ adapter.dispatch('get_intervals_between', packages = dbt_utils._get_utils_namespaces())(start_date, end_date, datepart) }}
+{%- endmacro %}
 
+{% macro default__get_intervals_between(start_date, end_date, datepart) -%}
     {%- call statement('get_intervals_between', fetch_result=True) %}
 
         select {{dbt_utils.datediff(start_date, end_date, datepart)}}
@@ -21,6 +24,10 @@
 
 
 {% macro date_spine(datepart, start_date, end_date) %}
+    {{ adapter.dispatch('date_spine', packages = dbt_utils._get_utils_namespaces())(datepart, start_date, end_date) }}
+{%- endmacro %}
+
+{% macro default__date_spine(datepart, start_date, end_date) %}
 
 /*
 call as follows:

macros/geo/haversine_distance.sql

@@ -7,6 +7,10 @@ The arguments should be float type.
 #}
 
 {% macro haversine_distance(lat1,lon1,lat2,lon2) -%}
+    {{ adapter.dispatch('haversine_distance', packages = dbt_utils._get_utils_namespaces())(lat1,lon1,lat2,lon2) }}
+{% endmacro %}
+
+{% macro default__haversine_distance(lat1,lon1,lat2,lon2) -%}
 
     2 * 3961 * asin(sqrt((sin(radians(({{lat2}} - {{lat1}}) / 2))) ^ 2 +
     cos(radians({{lat1}})) * cos(radians({{lat2}})) *

macros/logger/log_info.sql

@@ -1,5 +1,7 @@
 {% macro log_info(message) %}
+    {{ adapter.dispatch('log_info', packages = dbt_utils._get_utils_namespaces())(message) }}
+{% endmacro %}
 
+{% macro default__log_info(message) %}
     {{ log(dbt_utils.pretty_log_format(message), info=True) }}
-
 {% endmacro %}

macros/logger/pretty_log_format.sql

@@ -1,5 +1,7 @@
 {% macro pretty_log_format(message) %}
+    {{ adapter.dispatch('pretty_log_format', packages = dbt_utils._get_utils_namespaces())(message) }}
+{% endmacro %}
 
+{% macro default__pretty_log_format(message) %}
     {{ return( dbt_utils.pretty_time() ~ ' + ' ~ message) }}
-
 {% endmacro %}

macros/logger/pretty_time.sql

@@ -1,5 +1,7 @@
 {% macro pretty_time(format='%H:%M:%S') %}
+    {{ adapter.dispatch('pretty_time', packages = dbt_utils._get_utils_namespaces())(format='%H:%M:%S') }}
+{% endmacro %}
 
+{% macro default__pretty_time(format='%H:%M:%S') %}
     {{ return(modules.datetime.datetime.now().strftime(format)) }}
-
 {% endmacro %}

macros/materializations/insert_by_period_materialization.sql

@@ -1,4 +1,8 @@
 {% macro get_period_boundaries(target_schema, target_table, timestamp_field, start_date, stop_date, period) -%}
+    {{ adapter.dispatch('get_period_boundaries', packages = dbt_utils._get_utils_namespaces())(target_schema, target_table, timestamp_field, start_date, stop_date, period) }}
+{% endmacro %}
+
+{% macro default__get_period_boundaries(target_schema, target_table, timestamp_field, start_date, stop_date, period) -%}
 
   {% call statement('period_boundaries', fetch_result=True) -%}
     with data as (

macros/schema_tests/at_least_one.sql

@@ -1,4 +1,8 @@
 {% macro test_at_least_one(model) %}
+  {{ adapter.dispatch('test_at_least_one', packages = dbt_utils._get_utils_namespaces())(model, **kwargs) }}
+{% endmacro %}
+
+{% macro default__test_at_least_one(model) %}
 
 {% set column_name = kwargs.get('column_name', kwargs.get('arg')) %}
 
@@ -14,4 +18,4 @@ from (
 
 ) validation_errors
 
-{% endmacro %}
+{% endmacro %}

macros/schema_tests/cardinality_equality.sql

@@ -1,4 +1,9 @@
 {% macro test_cardinality_equality(model, to, field) %}
+    {{ adapter.dispatch('test_cardinality_equality', packages = dbt_utils._get_utils_namespaces())(model, to, field, **kwargs) }}
+
+{% endmacro %}
+
+{% macro default__test_cardinality_equality(model, to, field) %}
 
 {% set column_name = kwargs.get('column_name', kwargs.get('from')) %}
 

macros/schema_tests/equal_rowcount.sql

@@ -1,4 +1,8 @@
 {% macro test_equal_rowcount(model) %}
+  {{ adapter.dispatch('test_equal_rowcount', packages = dbt_utils._get_utils_namespaces())(model, **kwargs) }}
+{% endmacro %}
+
+{% macro default__test_equal_rowcount(model) %}
 
 {% set compare_model = kwargs.get('compare_model', kwargs.get('arg')) %}
 

macros/schema_tests/equality.sql

@@ -1,4 +1,8 @@
 {% macro test_equality(model) %}
+  {{ adapter.dispatch('test_equality', packages = dbt_utils._get_utils_namespaces())(model, **kwargs) }}
+{% endmacro %}
+
+{% macro default__test_equality(model) %}
 
 
 {#-- Prevent querying of db in parsing mode. This works because this macro does not create any new refs. #}

macros/schema_tests/expression_is_true.sql

@@ -1,4 +1,8 @@
 {% macro test_expression_is_true(model, condition='true') %}
+  {{ adapter.dispatch('test_expression_is_true', packages = dbt_utils._get_utils_namespaces())(model, condition='true', **kwargs) }}
+{% endmacro %}
+
+{% macro default__test_expression_is_true(model, condition='true') %}
 
 {% set expression = kwargs.get('expression', kwargs.get('arg')) %}
 

macros/schema_tests/mutually_exclusive_ranges.sql

@@ -1,4 +1,8 @@
 {% macro test_mutually_exclusive_ranges(model, lower_bound_column, upper_bound_column, partition_by=None, gaps='allowed') %}
+  {{ adapter.dispatch('test_mutually_exclusive_ranges', packages = dbt_utils._get_utils_namespaces())(model, lower_bound_column, upper_bound_column, partition_by=None, gaps='allowed') }}
+{% endmacro %}
+
+{% macro default__test_mutually_exclusive_ranges(model, lower_bound_column, upper_bound_column, partition_by=None, gaps='allowed') %}
 
 {% if gaps == 'not_allowed' %}
     {% set allow_gaps_operator='=' %}

macros/schema_tests/not_constant.sql

@@ -1,5 +1,9 @@
 
 {% macro test_not_constant(model) %}
+  {{ adapter.dispatch('test_not_constant', packages = dbt_utils._get_utils_namespaces())(model, **kwargs) }}
+{% endmacro %}
+
+{% macro default__test_not_constant(model) %}
 
 {% set column_name = kwargs.get('column_name', kwargs.get('arg')) %}
 

macros/schema_tests/recency.sql

@@ -1,4 +1,8 @@
 {% macro test_recency(model, datepart, interval) %}
+  {{ adapter.dispatch('test_recency', packages = dbt_utils._get_utils_namespaces())(model, datepart, interval, **kwargs) }}
+{% endmacro %}
+
+{% macro default__test_recency(model, datepart, interval) %}
 
 {% set column_name = kwargs.get('column_name', kwargs.get('field')) %}
 

macros/schema_tests/relationships_where.sql

@@ -1,4 +1,8 @@
 {% macro test_relationships_where(model, to, field) %}
+  {{ adapter.dispatch('test_relationships_where', packages = dbt_utils._get_utils_namespaces())(model, to, field, **kwargs) }}
+{% endmacro %}
+
+{% macro default__test_relationships_where(model, to, field) %}
 
 {% set column_name = kwargs.get('column_name', kwargs.get('from')) %}
 {% set from_condition = kwargs.get('from_condition', "true") %}

macros/schema_tests/test_not_null_where.sql

@@ -1,4 +1,8 @@
 {% macro test_not_null_where(model) %}
+  {{ adapter.dispatch('test_not_null_where', packages = dbt_utils._get_utils_namespaces())(model, **kwargs) }}
+{% endmacro %}
+
+{% macro default__test_not_null_where(model) %}
 
 {% set column_name = kwargs.get('column_name', kwargs.get('arg')) %}
 {% set where = kwargs.get('where', kwargs.get('arg')) %}

macros/schema_tests/test_unique_where.sql

@@ -1,4 +1,8 @@
 {% macro test_unique_where(model) %}
+  {{ adapter.dispatch('test_unique_where', packages = dbt_utils._get_utils_namespaces())(model, **kwargs) }}
+{% endmacro %}
+
+{% macro default__test_unique_where(model) %}
 
 {% set column_name = kwargs.get('column_name', kwargs.get('arg')) %}
 {% set where = kwargs.get('where', kwargs.get('arg')) %}

macros/schema_tests/unique_combination_of_columns.sql

@@ -1,4 +1,8 @@
 {% macro test_unique_combination_of_columns(model, quote_columns = false) %}
+  {{ adapter.dispatch('test_unique_combination_of_columns', packages = dbt_utils._get_utils_namespaces())(model, quote_columns = false, **kwargs) }}
+{% endmacro %}
+
+{% macro default__test_unique_combination_of_columns(model, quote_columns = false) %}
 
 {%- set columns = kwargs.get('combination_of_columns', kwargs.get('arg')) %}
 

macros/sql/generate_series.sql

@@ -1,4 +1,8 @@
 {% macro get_powers_of_two(upper_bound) %}
+    {{ adapter.dispatch('get_powers_of_two', packages = dbt_utils._get_utils_namespaces())(upper_bound) }}
+{% endmacro %}
+
+{% macro default__get_powers_of_two(upper_bound) %}
 
     {% if upper_bound <= 0 %}
     {{ exceptions.raise_compiler_error("upper bound must be positive") }}
@@ -12,6 +16,10 @@
 
 
 {% macro generate_series(upper_bound) %}
+    {{ adapter.dispatch('generate_series', packages = dbt_utils._get_utils_namespaces())(upper_bound) }}
+{% endmacro %}
+
+{% macro default__generate_series(upper_bound) %}
 
     {% set n = dbt_utils.get_powers_of_two(upper_bound) %}
 

macros/sql/get_column_values.sql

@@ -11,6 +11,10 @@ Returns:
 #}
 
 {% macro get_column_values(table, column, max_records=none, default=none) -%}
+    {{ adapter.dispatch('get_column_values', packages = dbt_utils._get_utils_namespaces())(table, column, max_records=none, default=none) }}
+{% endmacro %}
+
+{% macro default__get_column_values(table, column, max_records=none, default=none) -%}
 
 {#-- Prevent querying of db in parsing mode. This works because this macro does not create any new refs. #}
     {%- if not execute -%}

macros/sql/get_query_results_as_dict.sql

@@ -1,4 +1,9 @@
 {% macro get_query_results_as_dict(query) %}
+    {{ adapter.dispatch('get_query_results_as_dict', packages = dbt_utils._get_utils_namespaces())(query) }}
+{% endmacro %}
+
+{% macro default__get_query_results_as_dict(query) %}
+
 {# This macro returns a dictionary of the form {column_name: (tuple_of_results)} #}
 
     {%- call statement('get_query_results', fetch_result=True,auto_begin=false) -%}

macros/sql/get_relations_by_pattern.sql

@@ -1,4 +1,8 @@
 {% macro get_relations_by_pattern(schema_pattern, table_pattern, exclude='', database=target.database) %}
+    {{ adapter.dispatch('get_relations_by_pattern', packages = dbt_utils._get_utils_namespaces())(schema_pattern, table_pattern, exclude='', database=target.database) }}
+{% endmacro %}
+
+{% macro default__get_relations_by_pattern(schema_pattern, table_pattern, exclude='', database=target.database) %}
 
     {%- call statement('get_tables', fetch_result=True) %}
 

macros/sql/get_relations_by_prefix.sql

@@ -1,4 +1,8 @@
 {% macro get_relations_by_prefix(schema, prefix, exclude='', database=target.database) %}
+    {{ adapter.dispatch('get_relations_by_prefix', packages = dbt_utils._get_utils_namespaces())(schema, prefix, exclude='', database=target.database) }}
+{% endmacro %}
+
+{% macro default__get_relations_by_prefix(schema, prefix, exclude='', database=target.database) %}
 
     {%- call statement('get_tables', fetch_result=True) %}
 

macros/sql/get_tables_by_prefix_sql.sql

@@ -1,5 +1,9 @@
 {% macro get_tables_by_prefix_sql(schema, prefix, exclude='', database=target.database) %}
-
+    {{ adapter.dispatch('get_tables_by_prefix_sql', packages = dbt_utils._get_utils_namespaces())(schema, prefix, exclude='', database=target.database) }}
+{% endmacro %}
+
+{% macro default__get_tables_by_prefix_sql(schema, prefix, exclude='', database=target.database) %}
+
     {{ dbt_utils.get_tables_by_pattern_sql(
         schema_pattern = schema,
         table_pattern = prefix ~ '%',

macros/sql/groupby.sql

@@ -1,4 +1,8 @@
 {%- macro group_by(n) -%}
+    {{ adapter.dispatch('group_by', packages = dbt_utils._get_utils_namespaces())(n) }}
+{% endmacro %}
+
+{%- macro default__group_by(n) -%}
 
   group by {% for i in range(1, n + 1) -%}
       {{ i }}{{ ',' if not loop.last }}   

macros/sql/nullcheck.sql

@@ -1,4 +1,8 @@
 {% macro nullcheck(cols) %}
+    {{ adapter.dispatch('nullcheck', packages = dbt_utils._get_utils_namespaces())(cols) }}
+{% endmacro %}
+
+{% macro default__nullcheck(cols) %}
 {%- for col in cols %}
 
     {% if col.is_string() -%}

macros/sql/nullcheck_table.sql

@@ -1,4 +1,8 @@
 {% macro nullcheck_table(relation) %}
+    {{ adapter.dispatch('nullcheck_table', packages = dbt_utils._get_utils_namespaces())(relation) }}
+{% endmacro %}
+
+{% macro default__nullcheck_table(relation) %}
 
   {%- do dbt_utils._is_relation(relation, 'nullcheck_table') -%}
   {%- do dbt_utils._is_ephemeral(relation, 'nullcheck_table') -%}

macros/sql/pivot.sql

@@ -51,6 +51,20 @@ Arguments:
                else_value=0,
                quote_identifiers=True,
                distinct=False) %}
+    {{ adapter.dispatch('pivot', packages = dbt_utils._get_utils_namespaces())(column, values, alias=True, agg='sum', cmp='=', prefix='', suffix='', then_value=1, else_value=0, quote_identifiers=True, distinct=False) }}
+{% endmacro %}
+
+{% macro default__pivot(column,
+               values,
+               alias=True,
+               agg='sum',
+               cmp='=',
+               prefix='',
+               suffix='',
+               then_value=1,
+               else_value=0,
+               quote_identifiers=True,
+               distinct=False) %}
   {% for v in values %}
     {{ agg }}(
       {% if distinct %} distinct {% endif %}

macros/sql/safe_add.sql

@@ -1,4 +1,8 @@
 {%- macro safe_add() -%}
+    {{ adapter.dispatch('safe_add', packages = dbt_utils._get_utils_namespaces())() }}
+{% endmacro %}
+
+{%- macro default__safe_add() -%}
 
 {% set fields = [] %}
 

macros/sql/star.sql

@@ -1,5 +1,8 @@
 {% macro star(from, relation_alias=False, except=[]) -%}
+    {{ adapter.dispatch('star', packages = dbt_utils._get_utils_namespaces())(from, relation_alias=False, except=[]) }}
+{% endmacro %}
 
+{% macro default__star(from, relation_alias=False, except=[]) -%}
     {%- do dbt_utils._is_relation(from, 'star') -%}
     {%- do dbt_utils._is_ephemeral(from, 'star') -%}
 

macros/sql/surrogate_key.sql

@@ -1,4 +1,8 @@
 {%- macro surrogate_key(field_list) -%}
+    {{ adapter.dispatch('surrogate_key', packages = dbt_utils._get_utils_namespaces())(field_list) }}
+{% endmacro %}
+
+{%- macro default__surrogate_key(field_list) -%}
 
 {%- if varargs|length >= 1 or field_list is string %}
 

macros/sql/union.sql

@@ -1,4 +1,8 @@
 {%- macro union_relations(relations, column_override=none, include=[], exclude=[], source_column_name='_dbt_source_relation') -%}
+    {{ adapter.dispatch('union_relations', packages = dbt_utils._get_utils_namespaces())(relations, column_override=none, include=[], exclude=[], source_column_name='_dbt_source_relation') }}
+{% endmacro %}
+
+{%- macro default__union_relations(relations, column_override=none, include=[], exclude=[], source_column_name='_dbt_source_relation') -%}
 
     {%- if exclude and include -%}
         {{ exceptions.raise_compiler_error("Both an exclude and include list were provided to the `union` macro. Only one is allowed") }}

macros/sql/unpivot.sql

@@ -13,6 +13,10 @@ Arguments:
 #}
 
 {% macro unpivot(relation=none, cast_to='varchar', exclude=none, remove=none, field_name='field_name', value_name='value', table=none) -%}
+    {{ adapter.dispatch('unpivot', packages = dbt_utils._get_utils_namespaces())(relation=none, cast_to='varchar', exclude=none, remove=none, field_name='field_name', value_name='value', table=none) }}
+{% endmacro %}
+
+{% macro default__unpivot(relation=none, cast_to='varchar', exclude=none, remove=none, field_name='field_name', value_name='value', table=none) -%}
 
     {% if table %}
         {%- set error_message = '

macros/web/get_url_host.sql

@@ -1,4 +1,8 @@
 {% macro get_url_host(field) -%}
+    {{ adapter.dispatch('get_url_host', packages = dbt_utils._get_utils_namespaces())(field) }}
+{% endmacro %}
+
+{% macro default__get_url_host(field) -%}
 
 {%- set parsed = 
     dbt_utils.split_part(

macros/web/get_url_parameter.sql

@@ -1,4 +1,8 @@
 {% macro get_url_parameter(field, url_parameter) -%}
+    {{ adapter.dispatch('get_url_parameter', packages = dbt_utils._get_utils_namespaces())(field, url_parameter) }}
+{% endmacro %}
+
+{% macro default__get_url_parameter(field, url_parameter) -%}
 
 {%- set formatted_url_parameter = "'" + url_parameter + "='" -%}
 

macros/web/get_url_path.sql

@@ -1,4 +1,8 @@
 {% macro get_url_path(field) -%}
+    {{ adapter.dispatch('get_url_path', packages = dbt_utils._get_utils_namespaces())(field) }}
+{% endmacro %}
+
+{% macro default__get_url_path(field) -%}
 
     {%- set stripped_url = 
         dbt_utils.replace(