Add test for dedupe macro

dbt-labs · Mar 6, 2022 · 821c1d0 · 821c1d0
1 parent ea38b6b
commit 821c1d0
Show file tree

Hide file tree

Showing 4 changed files with 19 additions and 2 deletions.
diff --git a/integration_tests/data/sql/data_dedupe.csv b/integration_tests/data/sql/data_dedupe.csv
@@ -0,0 +1,3 @@
+user_id,event,version
+1,play,1
+1,play,2
diff --git a/integration_tests/data/sql/data_dedupe_expected.csv b/integration_tests/data/sql/data_dedupe_expected.csv
@@ -0,0 +1,2 @@
+user_id,event,version
+1,play,2
diff --git a/integration_tests/models/sql/schema.yml b/integration_tests/models/sql/schema.yml
@@ -85,7 +85,7 @@ models:
     tests:
       - dbt_utils.equality:
           compare_model: ref('data_pivot_expected')
-  
+
   - name: test_pivot_apostrophe
     tests:
       - dbt_utils.equality:
@@ -137,8 +137,13 @@ models:
     tests:
       - dbt_utils.equality:
           compare_model: ref('data_union_expected')
-          
+
   - name: test_get_relations_by_pattern
     tests:
       - dbt_utils.equality:
           compare_model: ref('data_union_events_expected')
+
+  - name: test_dedupe
+    tests:
+      - dbt_utils.equality:
+          compare_model: ref('data_dedupe_expected')
diff --git a/integration_tests/models/sql/test_dedupe.sql b/integration_tests/models/sql/test_dedupe.sql
@@ -0,0 +1,7 @@
+WITH deduped as (
+
+    {{ dbt_utils.dedupe(ref('data_dedupe'), group_by='user_id', order_by='version desc') | indent }}
+
+)
+
+select * from deduped