Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Tuva CC new #447

Merged
merged 3 commits into from
Apr 25, 2024
Merged

Tuva CC new #447

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
44c8d9d
Tuva CC new
cocozuloaga Apr 25, 2024
eb01182
reverted test_date_override to default (false)
thutuva Apr 25, 2024
60a37f8
fixing bq error and escaping apostrophe
thutuva Apr 25, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
79 changes: 25 additions & 54 deletions models/chronic_conditions/final/chronic_conditions__tuva_chronic_conditions_long.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -3,63 +3,34 @@
)
}}

with condition_row_number as (

select
patient_id
, normalized_code
, recorded_date
, row_number() over(
partition by
patient_id
, normalized_code
order by recorded_date asc
) as rn_asc
, row_number() over(
partition by
patient_id
, normalized_code
order by recorded_date desc
) as rn_desc
with all_conditions as (
select
patient_id,
normalized_code,
recorded_date
from {{ ref('tuva_chronic_conditions__stg_core__condition') }}
),

)

, patient_conditions as (

select
patient_id
, normalized_code as icd_10_cm
, max(
case
when rn_asc = 1
then recorded_date
end
) as first_diagnosis_date
, max(
case
when rn_desc = 1
then recorded_date
end
) as last_diagnosis_date
from condition_row_number
group by
patient_id
, normalized_code
conditions_with_first_and_last_diagnosis_date as (
select
patient_id,
normalized_code as icd_10_cm,
min(recorded_date) as first_diagnosis_date,
max(recorded_date) as last_diagnosis_date
from all_conditions
group by patient_id, normalized_code

)

select
pc.patient_id
, h.condition_family
, h.condition
, min(first_diagnosis_date) as first_diagnosis_date
, max(last_diagnosis_date) as last_diagnosis_date
, '{{ var('tuva_last_run')}}' as tuva_last_run
from {{ ref('chronic_conditions__tuva_chronic_conditions_hierarchy') }} h
inner join patient_conditions pc
on h.icd_10_cm_code = pc.icd_10_cm
group by
pc.patient_id
, h.condition_family
, h.condition

select
aa.patient_id,
bb.concept_name as condition,
min(first_diagnosis_date) as first_diagnosis_date,
max(last_diagnosis_date) as last_diagnosis_date,
'{{ var('tuva_last_run')}}' as tuva_last_run
from conditions_with_first_and_last_diagnosis_date aa
inner join {{ ref('value_set_member_relevant_fields') }} bb
on aa.icd_10_cm = bb.code
group by aa.patient_id, bb.concept_name
Loading
Loading