From 1cbcc6771545a044aa0c43c98a51e27a19ce57da Mon Sep 17 00:00:00 2001 From: Claire Carroll Date: Fri, 7 Jun 2019 15:33:46 -0400 Subject: [PATCH] Replace logging in insert-by-period materialization --- macros/materializations/insert_by_period_materialization.sql | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/macros/materializations/insert_by_period_materialization.sql b/macros/materializations/insert_by_period_materialization.sql index 618ff063..c486e451 100644 --- a/macros/materializations/insert_by_period_materialization.sql +++ b/macros/materializations/insert_by_period_materialization.sql @@ -115,7 +115,7 @@ -- commit each period as a separate transaction {% for i in range(num_periods) -%} {%- set msg = "Running for " ~ period ~ " " ~ (i + 1) ~ " of " ~ (num_periods) -%} - {{log(" + " ~ modules.datetime.datetime.now().strftime('%H:%M:%S') ~ " " ~ msg, info=True)}} + {{ dbt_utils.log_info(msg) }} {%- set tmp_identifier = model['name'] ~ '__dbt_incremental_period' ~ i ~ '_tmp' -%} {%- set tmp_relation = api.Relation.create(identifier=tmp_identifier, @@ -147,7 +147,7 @@ {%- if loop_vars.update({'sum_rows_inserted': sum_rows_inserted}) %} {% endif -%} {%- set msg = "Ran for " ~ period ~ " " ~ (i + 1) ~ " of " ~ (num_periods) ~ "; " ~ rows_inserted ~ " records inserted" -%} - {{log(" + " ~ modules.datetime.datetime.now().strftime('%H:%M:%S') ~ " " ~ msg, info=True)}} + {{ dbt_utils.log_info(msg) }} {%- endfor %}