diff --git a/models/final/eligibility.sql b/models/final/eligibility.sql index faad5e2..f4f0492 100644 --- a/models/final/eligibility.sql +++ b/models/final/eligibility.sql @@ -142,7 +142,7 @@ with eligibility_unpivot as ( , joined as ( select - cast(enrollment_span.desy_sort_key as {{ dbt.type_string() }} ) as patient_id + cast(enrollment_span.desy_sort_key as {{ dbt.type_string() }} ) as person_id , cast(enrollment_span.desy_sort_key as {{ dbt.type_string() }} ) as member_id , cast(enrollment_span.desy_sort_key as {{ dbt.type_string() }} ) as subscriber_id , case eligibility_unpivot.sex_code @@ -195,7 +195,7 @@ with eligibility_unpivot as ( ) select - patient_id + person_id , member_id , subscriber_id , gender diff --git a/models/final/medical_claim.sql b/models/final/medical_claim.sql index 0a3cf07..3e21fb4 100644 --- a/models/final/medical_claim.sql +++ b/models/final/medical_claim.sql @@ -28,7 +28,7 @@ with unioned as ( , member_months as ( select distinct - a.patient_id + a.person_id , year_nbr , month_nbr , a.payer @@ -46,7 +46,7 @@ select c.claim_id , c.claim_line_number , c.claim_type - , c.patient_id + , c.person_id , c.member_id , c.payer , c.plan @@ -192,6 +192,6 @@ select , c.ingest_datetime from unioned as c inner join member_months as mm - on c.patient_id = mm.patient_id + on c.person_id = mm.person_id and extract(year from c.claim_start_date) = mm.year_nbr and extract(month from c.claim_start_date) = mm.month_nbr \ No newline at end of file diff --git a/models/final/pharmacy_claim.sql b/models/final/pharmacy_claim.sql index f281615..3d355a1 100644 --- a/models/final/pharmacy_claim.sql +++ b/models/final/pharmacy_claim.sql @@ -1,7 +1,7 @@ select cast(null as {{ dbt.type_string() }}) as claim_id , cast(null as {{ dbt.type_string() }}) as claim_line_number - , cast(null as {{ dbt.type_string() }}) as patient_id + , cast(null as {{ dbt.type_string() }}) as person_id , cast(null as {{ dbt.type_string() }}) as member_id , cast(null as {{ dbt.type_string() }}) as payer , cast(null as {{ dbt.type_string() }}) as plan diff --git a/models/intermediate/carrier_claim.sql b/models/intermediate/carrier_claim.sql index 73bcc2e..c8366fc 100644 --- a/models/intermediate/carrier_claim.sql +++ b/models/intermediate/carrier_claim.sql @@ -26,7 +26,7 @@ select as claim_id , cast(l.line_num as integer) as claim_line_number , 'professional' as claim_type - , cast(b.desy_sort_key as {{ dbt.type_string() }} ) as patient_id + , cast(b.desy_sort_key as {{ dbt.type_string() }} ) as person_id , cast(b.desy_sort_key as {{ dbt.type_string() }} ) as member_id , cast('medicare' as {{ dbt.type_string() }} ) as payer , cast('medicare' as {{ dbt.type_string() }} ) as plan diff --git a/models/intermediate/dme_claim.sql b/models/intermediate/dme_claim.sql index 8d96b5d..3835f00 100644 --- a/models/intermediate/dme_claim.sql +++ b/models/intermediate/dme_claim.sql @@ -26,7 +26,7 @@ select as claim_id , cast(l.clm_line_num as integer) as claim_line_number , 'professional' as claim_type - , cast(b.desy_sort_key as {{ dbt.type_string() }} ) as patient_id + , cast(b.desy_sort_key as {{ dbt.type_string() }} ) as person_id , cast(b.desy_sort_key as {{ dbt.type_string() }} ) as member_id , cast('medicare' as {{ dbt.type_string() }} ) as payer , cast('medicare' as {{ dbt.type_string() }} ) as plan diff --git a/models/intermediate/home_health_claim.sql b/models/intermediate/home_health_claim.sql index b320bbb..4bc0ec1 100644 --- a/models/intermediate/home_health_claim.sql +++ b/models/intermediate/home_health_claim.sql @@ -41,7 +41,7 @@ select as claim_id , cast(l.clm_line_num as integer) as claim_line_number , 'institutional' as claim_type - , cast(b.desy_sort_key as {{ dbt.type_string() }} ) as patient_id + , cast(b.desy_sort_key as {{ dbt.type_string() }} ) as person_id , cast(b.desy_sort_key as {{ dbt.type_string() }} ) as member_id , cast('medicare' as {{ dbt.type_string() }} ) as payer , cast('medicare' as {{ dbt.type_string() }} ) as plan diff --git a/models/intermediate/hospice_claim.sql b/models/intermediate/hospice_claim.sql index 1f51d58..ad34788 100644 --- a/models/intermediate/hospice_claim.sql +++ b/models/intermediate/hospice_claim.sql @@ -41,7 +41,7 @@ select as claim_id , cast(l.clm_line_num as integer) as claim_line_number , 'institutional' as claim_type - , cast(b.desy_sort_key as {{ dbt.type_string() }} ) as patient_id + , cast(b.desy_sort_key as {{ dbt.type_string() }} ) as person_id , cast(b.desy_sort_key as {{ dbt.type_string() }} ) as member_id , cast('medicare' as {{ dbt.type_string() }} ) as payer , cast('medicare' as {{ dbt.type_string() }} ) as plan diff --git a/models/intermediate/inpatient_claim.sql b/models/intermediate/inpatient_claim.sql index a2ea89f..8190fa0 100644 --- a/models/intermediate/inpatient_claim.sql +++ b/models/intermediate/inpatient_claim.sql @@ -34,7 +34,7 @@ select b.claim_id , cast(l.clm_line_num as integer) as claim_line_number , 'institutional' as claim_type - , cast(b.desy_sort_key as {{ dbt.type_string() }} ) as patient_id + , cast(b.desy_sort_key as {{ dbt.type_string() }} ) as person_id , cast(b.desy_sort_key as {{ dbt.type_string() }} ) as member_id , cast('medicare' as {{ dbt.type_string() }} ) as payer , cast('medicare' as {{ dbt.type_string() }} ) as plan diff --git a/models/intermediate/outpatient_claim.sql b/models/intermediate/outpatient_claim.sql index 615aba6..7f1c094 100644 --- a/models/intermediate/outpatient_claim.sql +++ b/models/intermediate/outpatient_claim.sql @@ -44,7 +44,7 @@ select as claim_id , cast(l.clm_line_num as integer) as claim_line_number , 'institutional' as claim_type - , cast(b.desy_sort_key as {{ dbt.type_string() }} ) as patient_id + , cast(b.desy_sort_key as {{ dbt.type_string() }} ) as person_id , cast(b.desy_sort_key as {{ dbt.type_string() }} ) as member_id , cast('medicare' as {{ dbt.type_string() }} ) as payer , cast('medicare' as {{ dbt.type_string() }} ) as plan diff --git a/models/intermediate/snf_claim.sql b/models/intermediate/snf_claim.sql index 7f00f41..a032f36 100644 --- a/models/intermediate/snf_claim.sql +++ b/models/intermediate/snf_claim.sql @@ -44,7 +44,7 @@ select b.claim_id , cast(l.clm_line_num as integer) as claim_line_number , 'institutional' as claim_type - , cast(b.desy_sort_key as {{ dbt.type_string() }}) as patient_id + , cast(b.desy_sort_key as {{ dbt.type_string() }}) as person_id , cast(b.desy_sort_key as {{ dbt.type_string() }}) as member_id , cast('medicare' as {{ dbt.type_string() }} ) as payer , cast('medicare' as {{ dbt.type_string() }} ) as plan diff --git a/packages.yml b/packages.yml index 182c310..db557d8 100644 --- a/packages.yml +++ b/packages.yml @@ -2,4 +2,4 @@ packages: - package: dbt-labs/dbt_utils version: [">=0.9.2","<1.3.0"] - package: tuva-health/the_tuva_project - version: [">=0.10.0","<0.11.0"] + version: [">=0.13.0","<0.14.0"]