Recency truncate date option

.circleci/config.yml

@@ -23,7 +23,9 @@ jobs:
           name: "Run OG Tests - Postgres"
           command: ./run_test.sh postgres
       - store_artifacts:
-          path: ./logs
+          path: integration_tests/logs
+      - store_artifacts:
+          path: integration_tests/target
 
   integration-redshift:
     docker:
@@ -35,7 +37,9 @@ jobs:
           name: "Run OG Tests - Redshift"
           command: ./run_test.sh redshift
       - store_artifacts:
-          path: ./logs
+          path: integration_tests/logs
+      - store_artifacts:
+          path: integration_tests/target
 
   integration-snowflake:
     docker:
@@ -47,8 +51,10 @@ jobs:
           name: "Run OG Tests - Snowflake"
           command: ./run_test.sh snowflake
       - store_artifacts:
-          path: ./logs          
-
+          path: integration_tests/logs          
+      - store_artifacts:
+          path: integration_tests/target
+
   integration-bigquery:
     environment:
       BIGQUERY_SERVICE_KEY_PATH: "/home/circleci/bigquery-service-key.json"
@@ -64,7 +70,9 @@ jobs:
           name: "Run OG Tests - BigQuery"
           command: ./run_test.sh bigquery
       - store_artifacts:
-          path: ./logs
+          path: integration_tests/logs
+      - store_artifacts:
+          path: integration_tests/target
 
 workflows:
   version: 2

integration_tests/models/generic_tests/recency_time_excluded.sql

@@ -0,0 +1,12 @@
+with yesterday_time as (
+select
+    1 as col1,
+    2 as col2,
+    {{ dbt.dateadd('day', -1, dbt.current_timestamp()) }} as created_at
+)
+
+select 
+    col1, 
+    col2, 
+    {{ dbt.date_trunc('day', 'created_at') }} as created_at
+from yesterday_time

integration_tests/models/generic_tests/recency_time_included.sql

@@ -0,0 +1,4 @@
+select
+    1 as col1,
+    2 as col2,
+    cast({{ dbt.dateadd('hour', -23, dbt.current_timestamp()) }} as {{ dbt.type_timestamp() }}) as created_at

integration_tests/models/generic_tests/schema.yml

@@ -143,23 +143,38 @@ seeds:
               at_least: 0.9
 
 models:
-  - name: test_recency
+  - name: recency_time_included
     tests:
       - dbt_utils.recency:
           datepart: day
-          field: today
+          field: created_at
           interval: 1
       - dbt_utils.recency:
           datepart: day
-          field: today
+          field: created_at
           interval: 1
           group_by_columns: ['col1']
       - dbt_utils.recency:
           datepart: day
-          field: today
+          field: created_at
           interval: 1
           group_by_columns: ['col1', 'col2']
 
+  - name: recency_time_excluded
+    tests:
+      - dbt_utils.recency:
+          datepart: day
+          field: created_at
+          interval: 1
+          ignore_time_component: true
+      - dbt_utils.recency:
+          datepart: day
+          field: created_at
+          interval: 1
+          ignore_time_component: false
+          error_if: "<1" #sneaky way to ensure that the test is returning failing rows
+          warn_if: "<0"
+
   - name: test_equal_rowcount
     tests:
       - dbt_utils.equal_rowcount:

macros/generic_tests/recency.sql

@@ -1,10 +1,10 @@
-{% test recency(model, field, datepart, interval, group_by_columns = []) %}
-  {{ return(adapter.dispatch('test_recency', 'dbt_utils')(model, field, datepart, interval, group_by_columns)) }}
+{% test recency(model, field, datepart, interval, ignore_time_component=False, group_by_columns = []) %}
+  {{ return(adapter.dispatch('test_recency', 'dbt_utils')(model, field, datepart, interval, ignore_time_component, group_by_columns)) }}
 {% endtest %}
 
-{% macro default__test_recency(model, field, datepart, interval, group_by_columns) %}
+{% macro default__test_recency(model, field, datepart, interval, ignore_time_component, group_by_columns) %}
 
-{% set threshold = dbt.dateadd(datepart, interval * -1, current_timestamp_backcompat()) %}
+{% set threshold = 'cast(' ~ dbt.dateadd(datepart, interval * -1, dbt.current_timestamp()) ~ ' as ' ~ ('date' if ignore_time_component else dbt.type_timestamp()) ~ ')'  %}
 
 {% if group_by_columns|length() > 0 %}
   {% set select_gb_cols = group_by_columns|join(' ,') + ', ' %}
@@ -17,7 +17,11 @@ with recency as (
     select 
 
       {{ select_gb_cols }}
-      max({{field}}) as most_recent
+      {% if ignore_time_component %}
+        cast(max({{ field }}) as date) as most_recent
+      {%- else %}
+        max({{ field }}) as most_recent
+      {%- endif %}
 
     from {{ model }}