AHRQ PQI measures

integration_tests/dbt_project.yml

@@ -2,7 +2,7 @@ name: 'integration_tests'
 version: '1.0.0'
 config-version: 2
 
-profile: default
+profile: default 
 
 vars:
 

integration_tests/package-lock.yml

@@ -0,0 +1,5 @@
+packages:
+- local: ../
+- package: dbt-labs/dbt_utils
+  version: 1.1.1
+sha1_hash: de2deba3d66ce03d8c02949013650cc9b94f6030

models/ahrq_measures/pqi/final/ahrq_measures__pqi_denom_long.sql

@@ -0,0 +1,101 @@
+{{ config(
+    enabled = var('pqi_enabled', var('claims_enabled', var('tuva_marts_enabled', False))) | as_bool
+) }}
+
+select
+    d.year_number
+  , d.patient_id
+  , d.data_source
+  , 1 as pqi_number
+  , '{{ var('tuva_last_run')}}' as tuva_last_run
+from {{ ref('ahrq_measures__int_pqi_01_denom') }} as d
+
+union all
+
+select
+    d.year_number
+  , d.patient_id
+  , d.data_source
+  , 3 as pqi_number
+  , '{{ var('tuva_last_run')}}' as tuva_last_run
+from {{ ref('ahrq_measures__int_pqi_03_denom') }} as d
+
+union all
+
+select
+    d.year_number
+  , d.patient_id
+  , d.data_source
+  , 5 as pqi_number
+  , '{{ var('tuva_last_run')}}' as tuva_last_run
+from {{ ref('ahrq_measures__int_pqi_05_denom') }} as d
+
+union all
+
+select
+    d.year_number
+  , d.patient_id
+  , d.data_source
+  , 7 as pqi_number
+  , '{{ var('tuva_last_run')}}' as tuva_last_run
+from {{ ref('ahrq_measures__int_pqi_07_denom') }} as d
+
+union all
+
+select
+    d.year_number
+  , d.patient_id
+  , d.data_source
+  , 8 as pqi_number
+  , '{{ var('tuva_last_run')}}' as tuva_last_run
+from {{ ref('ahrq_measures__int_pqi_08_denom') }} as d
+
+union all
+
+select
+    d.year_number
+  , d.patient_id
+  , d.data_source
+  , 11 as pqi_number
+  , '{{ var('tuva_last_run')}}' as tuva_last_run
+from {{ ref('ahrq_measures__int_pqi_11_denom') }} as d
+
+union all
+
+select
+    d.year_number
+  , d.patient_id
+  , d.data_source
+  , 12 as pqi_number
+  , '{{ var('tuva_last_run')}}' as tuva_last_run
+from {{ ref('ahrq_measures__int_pqi_12_denom') }} as d
+
+union all
+
+select
+    d.year_number
+  , d.patient_id
+  , d.data_source
+  , 14 as pqi_number
+  , '{{ var('tuva_last_run')}}' as tuva_last_run
+from {{ ref('ahrq_measures__int_pqi_14_denom') }} as d
+
+union all
+
+select
+    d.year_number
+  , d.patient_id
+  , d.data_source
+  , 15 as pqi_number
+  , '{{ var('tuva_last_run')}}' as tuva_last_run
+from {{ ref('ahrq_measures__int_pqi_15_denom') }} as d
+
+union all
+
+select
+    d.year_number
+  , d.patient_id
+  , d.data_source
+  , 16 as pqi_number
+  , '{{ var('tuva_last_run')}}' as tuva_last_run
+from {{ ref('ahrq_measures__int_pqi_16_denom') }} as d

models/ahrq_measures/pqi/final/ahrq_measures__pqi_exclusion_long.sql

@@ -0,0 +1,111 @@
+{{ config(
+    enabled = var('pqi_enabled', var('claims_enabled', var('clinical_enabled', var('tuva_marts_enabled', False)))) | as_bool
+) }}
+
+select
+    e.data_source
+  , e.encounter_id
+  , e.exclusion_reason
+  , e.exclusion_number
+  , 1 as pqi_number
+  , '{{ var('tuva_last_run')}}' as tuva_last_run
+from {{ ref('ahrq_measures__int_pqi_01_exclusions') }} as e
+
+union all
+
+select
+    e.data_source
+  , e.encounter_id
+  , e.exclusion_reason
+  , e.exclusion_number
+  , 3 as pqi_number
+  , '{{ var('tuva_last_run')}}' as tuva_last_run
+from {{ ref('ahrq_measures__int_pqi_03_exclusions') }} as e
+
+union all
+
+select
+    e.data_source
+  , e.encounter_id
+  , e.exclusion_reason
+  , e.exclusion_number
+  , 5 as pqi_number
+  , '{{ var('tuva_last_run')}}' as tuva_last_run
+from {{ ref('ahrq_measures__int_pqi_05_exclusions') }} as e
+
+union all
+
+select
+    e.data_source
+  , e.encounter_id
+  , e.exclusion_reason
+  , e.exclusion_number
+  , 7 as pqi_number
+  , '{{ var('tuva_last_run')}}' as tuva_last_run
+from {{ ref('ahrq_measures__int_pqi_07_exclusions') }} as e
+
+union all
+
+select
+    e.data_source
+  , e.encounter_id
+  , e.exclusion_reason
+  , e.exclusion_number
+  , 8 as pqi_number
+  , '{{ var('tuva_last_run')}}' as tuva_last_run
+from {{ ref('ahrq_measures__int_pqi_08_exclusions') }} as e
+
+union all
+
+select
+    e.data_source
+  , e.encounter_id
+  , e.exclusion_reason
+  , e.exclusion_number
+  , 11 as pqi_number
+  , '{{ var('tuva_last_run')}}' as tuva_last_run
+from {{ ref('ahrq_measures__int_pqi_11_exclusions') }} as e
+
+union all
+
+select
+    e.data_source
+  , e.encounter_id
+  , e.exclusion_reason
+  , e.exclusion_number
+  , 12 as pqi_number
+  , '{{ var('tuva_last_run')}}' as tuva_last_run
+from {{ ref('ahrq_measures__int_pqi_12_exclusions') }} as e
+
+union all
+
+select
+    e.data_source
+  , e.encounter_id
+  , e.exclusion_reason
+  , e.exclusion_number
+  , 14 as pqi_number
+  , '{{ var('tuva_last_run')}}' as tuva_last_run
+from {{ ref('ahrq_measures__int_pqi_14_exclusions') }} as e
+
+union all
+
+select
+    e.data_source
+  , e.encounter_id
+  , e.exclusion_reason
+  , e.exclusion_number
+  , 15 as pqi_number
+  , '{{ var('tuva_last_run')}}' as tuva_last_run
+from {{ ref('ahrq_measures__int_pqi_15_exclusions') }} as e
+
+union all
+
+select
+    e.data_source
+  , e.encounter_id
+  , e.exclusion_reason
+  , e.exclusion_number
+  , 16 as pqi_number
+  , '{{ var('tuva_last_run')}}' as tuva_last_run
+from {{ ref('ahrq_measures__int_pqi_16_exclusions') }} as e

models/ahrq_measures/pqi/final/ahrq_measures__pqi_num_long.sql

@@ -0,0 +1,111 @@
+{{ config(
+    enabled = var('pqi_enabled', var('claims_enabled', var('tuva_marts_enabled', False))) | as_bool
+) }}
+
+select
+    n.data_source
+  , n.patient_id
+  , n.year_number
+  , n.encounter_id
+  , 1 as pqi_number
+  , '{{ var('tuva_last_run')}}' as tuva_last_run
+from {{ ref('ahrq_measures__int_pqi_01_num') }} as n
+
+union all
+
+select
+    n.data_source
+  , n.patient_id
+  , n.year_number
+  , n.encounter_id
+  , 3 as pqi_number
+  , '{{ var('tuva_last_run')}}' as tuva_last_run
+from {{ ref('ahrq_measures__int_pqi_03_num') }} as n
+
+union all
+
+select
+    n.data_source
+  , n.patient_id
+  , n.year_number
+  , n.encounter_id
+  , 5 as pqi_number
+  , '{{ var('tuva_last_run')}}' as tuva_last_run
+from {{ ref('ahrq_measures__int_pqi_05_num') }} as n
+
+union all
+
+select
+    n.data_source
+  , n.patient_id
+  , n.year_number
+  , n.encounter_id
+  , 7 as pqi_number
+  , '{{ var('tuva_last_run')}}' as tuva_last_run
+from {{ ref('ahrq_measures__int_pqi_07_num') }} as n
+
+union all
+
+select
+    n.data_source
+  , n.patient_id
+  , n.year_number
+  , n.encounter_id
+  , 8 as pqi_number
+  , '{{ var('tuva_last_run')}}' as tuva_last_run
+from {{ ref('ahrq_measures__int_pqi_08_num') }} as n
+
+union all
+
+select
+    n.data_source
+  , n.patient_id
+  , n.year_number
+  , n.encounter_id
+  , 11 as pqi_number
+  , '{{ var('tuva_last_run')}}' as tuva_last_run
+from {{ ref('ahrq_measures__int_pqi_11_num') }} as n
+
+union all
+
+select
+    n.data_source
+  , n.patient_id
+  , n.year_number
+  , n.encounter_id
+  , 12 as pqi_number
+  , '{{ var('tuva_last_run')}}' as tuva_last_run
+from {{ ref('ahrq_measures__int_pqi_12_num') }} as n
+
+union all
+
+select
+    n.data_source
+  , n.patient_id
+  , n.year_number
+  , n.encounter_id
+  , 14 as pqi_number
+  , '{{ var('tuva_last_run')}}' as tuva_last_run
+from {{ ref('ahrq_measures__int_pqi_14_num') }} as n
+
+union all
+
+select
+    n.data_source
+  , n.patient_id
+  , n.year_number
+  , n.encounter_id
+  , 15 as pqi_number
+  , '{{ var('tuva_last_run')}}' as tuva_last_run
+from {{ ref('ahrq_measures__int_pqi_15_num') }} as n
+
+union all
+
+select
+    n.data_source
+  , n.patient_id
+  , n.year_number
+  , n.encounter_id
+  , 16 as pqi_number
+  , '{{ var('tuva_last_run')}}' as tuva_last_run
+from {{ ref('ahrq_measures__int_pqi_16_num') }} as n

models/ahrq_measures/pqi/final/ahrq_measures__pqi_rate.sql

@@ -0,0 +1,44 @@
+{{ config(
+     enabled = var('pqi_enabled', var('claims_enabled', var('tuva_marts_enabled', False))) | as_bool
+   )
+}}
+
+with num as (
+    select
+        data_source
+      , year_number
+      , pqi_number
+      , count(encounter_id) as num_count
+    from {{ ref('ahrq_measures__pqi_num_long') }}
+    group by
+        data_source
+      , year_number
+      , pqi_number
+)
+
+, denom as (
+    select
+        data_source
+      , year_number
+      , pqi_number
+      , count(patient_id) as denom_count
+    from {{ ref('ahrq_measures__pqi_denom_long') }} as d
+    group by
+        data_source
+      , year_number
+      , pqi_number
+)
+
+select
+    d.data_source
+  , d.year_number
+  , d.pqi_number
+  , d.denom_count
+  , coalesce(num.num_count, 0) as num_count
+  , coalesce(num.num_count, 0) / d.denom_count * 100000 as rate_per_100_thousand
+  , '{{ var('tuva_last_run') }}' as tuva_last_run
+from denom as d
+left join num
+    on d.pqi_number = num.pqi_number
+    and d.year_number = num.year_number
+    and d.data_source = num.data_source