macro to compare tables by row

Author: fvankrieken

…scl/models/etl_dev_qa/qa__saf_by_row.sql …oducts/cscl/macros/qa_compare_by_row.sqlproducts/cscl/models/etl_dev_qa/qa__saf_by_row.sql renamed to products/cscl/macros/qa_compare_by_row.sql products/cscl/models/etl_dev_qa/qa__saf_by_row.sql renamed to products/cscl/macros/qa_compare_by_row.sql

@@ -1,11 +1,9 @@
-{{ config(
-    materialized = 'table',
-) }}
+{% macro compare_by_row(model) -%}
 WITH dev AS (
-    SELECT * FROM {{ ref('saf_abcegnpx_generic') }}
+    SELECT * FROM {{ ref(model) }}
 ),
 prod AS (
-    SELECT * FROM {{ source('production_outputs', 'saf_abcegnpx_generic') }}
+    SELECT * FROM {{ source('production_outputs', model) }}
 ),
 combined AS (
     SELECT
@@ -30,4 +28,4 @@ counts AS (
 )
 SELECT * FROM counts
 WHERE dev_count <> prod_count
-ORDER BY counts.boroughcode, counts.face_code, counts.segment_seqnum, source
+{%- endmacro %}

products/cscl/models/etl_dev_qa/qa__saf_abcegnpx_generic.sql

@@ -0,0 +1,5 @@
+{{ config(
+    materialized = 'table',
+) }}
+{{ qa_compare_by_row('saf_abcegnpx_generic') }}
+ORDER BY counts.boroughcode, counts.face_code, counts.segment_seqnum, source

products/cscl/models/etl_dev_qa/qa__saf_abcegnpx_roadbed.sql

@@ -0,0 +1,5 @@
+{{ config(
+    materialized = 'table',
+) }}
+{{ qa_compare_by_row('saf_abcegnpx_roadbed') }}
+ORDER BY counts.boroughcode, counts.face_code, counts.segment_seqnum, source

products/cscl/models/etl_dev_qa/qa__saf_d_generic.sql

@@ -0,0 +1,5 @@
+{{ config(
+    materialized = 'table',
+) }}
+{{ qa_compare_by_row('saf_d_generic') }}
+ORDER BY counts.boroughcode, counts.face_code, counts.segment_seqnum, source

products/cscl/models/etl_dev_qa/qa__saf_d_roadbed.sql

@@ -0,0 +1,5 @@
+{{ config(
+    materialized = 'table',
+) }}
+{{ qa_compare_by_row('saf_d_roadbed') }}
+ORDER BY counts.boroughcode, counts.face_code, counts.segment_seqnum, source