From 22f6ae3e6adc2a9ea7be737ab4ffb9afc8606802 Mon Sep 17 00:00:00 2001 From: a-pfeiffer Date: Thu, 7 Aug 2025 07:51:53 -0400 Subject: [PATCH 1/4] DBDAART-15350 - Removed '3' from valid values in DGNS CD IND fields in IPH and IP_DX --- taf/IP/IPH.py | 26 +++++++++++++------------- taf/IP/IP_DX.py | 2 +- 2 files changed, 14 insertions(+), 14 deletions(-) diff --git a/taf/IP/IPH.py b/taf/IP/IPH.py index 6c4d8bb..ac5e5ae 100644 --- a/taf/IP/IPH.py +++ b/taf/IP/IPH.py @@ -97,42 +97,42 @@ def create(self, runner: IP_Runner): else cast(BIRTH_WT_GRMS_QTY as decimal(9, 3)) end as BIRTH_WT_GRMS_QTY , { TAF_Closure.var_set_fills('ADMTG_DGNS_CD', cond1='0', cond2='8', cond3='9', cond4='#') } - , { TAF_Closure.var_set_type2('ADMTG_DGNS_CD_IND', 0, cond1='1', cond2='2', cond3='3') } + , { TAF_Closure.var_set_type2('ADMTG_DGNS_CD_IND', 0, cond1='1', cond2='2') } , { TAF_Closure.var_set_fills('DGNS_1_CD', cond1='0', cond2='8', cond3='9', cond4='#') } - , { TAF_Closure.var_set_type2('DGNS_1_CD_IND', 0, cond1='1', cond2='2', cond3='3') } + , { TAF_Closure.var_set_type2('DGNS_1_CD_IND', 0, cond1='1', cond2='2') } , { TAF_Closure.var_set_poa('DGNS_POA_1_CD_IND') } , { TAF_Closure.var_set_fills('DGNS_2_CD', cond1='0', cond2='8', cond3='9', cond4='#') } - , { TAF_Closure.var_set_type2('DGNS_2_CD_IND', 0, cond1='1', cond2='2', cond3='3') } + , { TAF_Closure.var_set_type2('DGNS_2_CD_IND', 0, cond1='1', cond2='2') } , { TAF_Closure.var_set_poa('DGNS_POA_2_CD_IND') } , { TAF_Closure.var_set_fills('DGNS_3_CD', cond1='0', cond2='8', cond3='9', cond4='#') } - , { TAF_Closure.var_set_type2('DGNS_3_CD_IND', 0, cond1='1', cond2='2', cond3='3') } + , { TAF_Closure.var_set_type2('DGNS_3_CD_IND', 0, cond1='1', cond2='2') } , { TAF_Closure.var_set_poa('DGNS_POA_3_CD_IND') } , { TAF_Closure.var_set_fills('DGNS_4_CD', cond1='0', cond2='8', cond3='9', cond4='#') } - , { TAF_Closure.var_set_type2('DGNS_4_CD_IND', 0, cond1='1', cond2='2', cond3='3') } + , { TAF_Closure.var_set_type2('DGNS_4_CD_IND', 0, cond1='1', cond2='2') } , { TAF_Closure.var_set_poa('DGNS_POA_4_CD_IND') } , { TAF_Closure.var_set_fills('DGNS_5_CD', cond1='0', cond2='8', cond3='9', cond4='#') } - , { TAF_Closure.var_set_type2('DGNS_5_CD_IND', 0, cond1='1', cond2='2', cond3='3') } + , { TAF_Closure.var_set_type2('DGNS_5_CD_IND', 0, cond1='1', cond2='2') } , { TAF_Closure.var_set_poa('DGNS_POA_5_CD_IND') } , { TAF_Closure.var_set_fills('DGNS_6_CD', cond1='0', cond2='8', cond3='9', cond4='#') } - , { TAF_Closure.var_set_type2('DGNS_6_CD_IND', 0, cond1='1', cond2='2', cond3='3') } + , { TAF_Closure.var_set_type2('DGNS_6_CD_IND', 0, cond1='1', cond2='2') } , { TAF_Closure.var_set_poa('DGNS_POA_6_CD_IND') } , { TAF_Closure.var_set_fills('DGNS_7_CD', cond1='0', cond2='8', cond3='9', cond4='#') } - , { TAF_Closure.var_set_type2('DGNS_7_CD_IND', 0, cond1='1', cond2=2, cond3='3') } + , { TAF_Closure.var_set_type2('DGNS_7_CD_IND', 0, cond1='1', cond2='2') } , { TAF_Closure.var_set_poa('DGNS_POA_7_CD_IND') } , { TAF_Closure.var_set_fills('DGNS_8_CD', cond1='0', cond2='8', cond3='9', cond4='#') } - , { TAF_Closure.var_set_type2('DGNS_8_CD_IND', 0, cond1='1', cond2='2', cond3='3') } + , { TAF_Closure.var_set_type2('DGNS_8_CD_IND', 0, cond1='1', cond2='2') } , { TAF_Closure.var_set_poa('DGNS_POA_8_CD_IND') } , { TAF_Closure.var_set_fills('DGNS_9_CD', cond1='0', cond2='8', cond3='9', cond4='#') } - , { TAF_Closure.var_set_type2('DGNS_9_CD_IND', 0, cond1='1', cond2='2', cond3='3') } + , { TAF_Closure.var_set_type2('DGNS_9_CD_IND', 0, cond1='1', cond2='2') } , { TAF_Closure.var_set_poa('DGNS_POA_9_CD_IND') } , { TAF_Closure.var_set_fills('DGNS_10_CD', cond1='0', cond2='8', cond3='9', cond4='#') } - , { TAF_Closure.var_set_type2('DGNS_10_CD_IND', 0, cond1=1, cond2=2, cond3='3') } + , { TAF_Closure.var_set_type2('DGNS_10_CD_IND', 0, cond1='1', cond2='2') } , { TAF_Closure.var_set_poa('DGNS_POA_10_CD_IND') } , { TAF_Closure.var_set_fills('DGNS_11_CD', cond1='0', cond2='8', cond3='9', cond4='#') } - , { TAF_Closure.var_set_type2('DGNS_11_CD_IND', 0, cond1='1', cond2='2', cond3='3') } + , { TAF_Closure.var_set_type2('DGNS_11_CD_IND', 0, cond1='1', cond2='2') } , { TAF_Closure.var_set_poa('DGNS_POA_11_CD_IND') } , { TAF_Closure.var_set_fills('DGNS_12_CD', cond1='0', cond2='8', cond3='9', cond4='#') } - , { TAF_Closure.var_set_type2('DGNS_12_CD_IND', 0, cond1='1', cond2='2', cond3='3') } + , { TAF_Closure.var_set_type2('DGNS_12_CD_IND', 0, cond1='1', cond2='2') } , { TAF_Closure.var_set_poa('DGNS_POA_12_CD_IND') } , DRG_CD diff --git a/taf/IP/IP_DX.py b/taf/IP/IP_DX.py index 0fbaa20..c0915d3 100644 --- a/taf/IP/IP_DX.py +++ b/taf/IP/IP_DX.py @@ -38,7 +38,7 @@ def create(self, runner: IP_Runner): end as ADJDCTN_DT , case when trim(upper(dgns_type_cd)) in {tuple(TAF_Metadata.DGNS_TYPE_CD_values)} then trim(upper(dgns_type_cd)) else NULL end as DGNS_TYPE_CD , DGNS_SQNC_NUM - ,{ TAF_Closure.var_set_type2('DGNS_CD_IND', 0, cond1='1', cond2='2', cond3='3') } + ,{ TAF_Closure.var_set_type2('DGNS_CD_IND', 0, cond1='1', cond2='2') } ,{ TAF_Closure.var_set_type1('DGNS_CD') } ,{ TAF_Closure.var_set_type4('DGNS_POA_IND', 'YES', cond1='Y', cond2='N', cond3='U', cond4='W', cond5='1') } ,from_utc_timestamp(current_timestamp(), 'EST') as REC_ADD_TS From 0c7f694e73cf04f878ce177826a224bf98e6a20e Mon Sep 17 00:00:00 2001 From: a-pfeiffer Date: Thu, 7 Aug 2025 08:02:44 -0400 Subject: [PATCH 2/4] DBDAART-15350- LT - Removed "3" from valid values for all DGNS_CD_IND fields in LTH and LT_DX. --- taf/LT/LTH.py | 12 ++++++------ taf/LT/LT_DX.py | 2 +- 2 files changed, 7 insertions(+), 7 deletions(-) diff --git a/taf/LT/LTH.py b/taf/LT/LTH.py index a39406d..d952356 100644 --- a/taf/LT/LTH.py +++ b/taf/LT/LTH.py @@ -82,21 +82,21 @@ def create(self, runner: LT_Runner): , { TAF_Closure.var_set_type2(var='HLTH_CARE_ACQRD_COND_CD', lpad=0, cond1='0', cond2='1') } , { TAF_Closure.var_set_ptstatus('PTNT_STUS_CD') } , { TAF_Closure.var_set_fills('ADMTG_DGNS_CD', cond1='0', cond2='8', cond3='9', cond4='#') } - , { TAF_Closure.var_set_type2(var='ADMTG_DGNS_CD_IND', lpad=0, cond1='1', cond2='2', cond3='3') } + , { TAF_Closure.var_set_type2(var='ADMTG_DGNS_CD_IND', lpad=0, cond1='1', cond2='2') } , { TAF_Closure.var_set_fills('DGNS_1_CD', cond1='0', cond2='8', cond3='9', cond4='#') } - , { TAF_Closure.var_set_type2(var='DGNS_1_CD_IND', lpad=0, cond1='1', cond2='2', cond3='3') } + , { TAF_Closure.var_set_type2(var='DGNS_1_CD_IND', lpad=0, cond1='1', cond2='2') } , { TAF_Closure.var_set_poa('DGNS_POA_1_CD_IND') } , { TAF_Closure.var_set_fills('DGNS_2_CD', cond1='0', cond2='8', cond3='9', cond4='#') } - , { TAF_Closure.var_set_type2(var='DGNS_2_CD_IND', lpad=0, cond1='1', cond2='2', cond3='3') } + , { TAF_Closure.var_set_type2(var='DGNS_2_CD_IND', lpad=0, cond1='1', cond2='2') } , { TAF_Closure.var_set_poa('DGNS_POA_2_CD_IND') } , { TAF_Closure.var_set_fills('DGNS_3_CD', cond1='0', cond2='8', cond3='9', cond4='#') } - , { TAF_Closure.var_set_type2(var='DGNS_3_CD_IND', lpad=0, cond1='1', cond2='2', cond3='3') } + , { TAF_Closure.var_set_type2(var='DGNS_3_CD_IND', lpad=0, cond1='1', cond2='2') } , { TAF_Closure.var_set_poa('DGNS_POA_3_CD_IND') } , { TAF_Closure.var_set_fills('DGNS_4_CD', cond1='0', cond2='8', cond3='9', cond4='#') } - , { TAF_Closure.var_set_type2(var='DGNS_4_CD_IND', lpad=0, cond1='1', cond2='2', cond3='3') } + , { TAF_Closure.var_set_type2(var='DGNS_4_CD_IND', lpad=0, cond1='1', cond2='2') } , { TAF_Closure.var_set_poa('DGNS_POA_4_CD_IND') } , { TAF_Closure.var_set_fills('DGNS_5_CD', cond1='0', cond2='8', cond3='9', cond4='#') } - , { TAF_Closure.var_set_type2(var='DGNS_5_CD_IND', lpad=0, cond1='1', cond2='2', cond3='3') } + , { TAF_Closure.var_set_type2(var='DGNS_5_CD_IND', lpad=0, cond1='1', cond2='2') } , { TAF_Closure.var_set_poa('DGNS_POA_5_CD_IND') } , { TAF_Closure.var_set_type6('NCVRD_DAYS_CNT', cond1='88888') } , { TAF_Closure.var_set_type6('NCVRD_CHRGS_AMT', cond1='888888888.88') } diff --git a/taf/LT/LT_DX.py b/taf/LT/LT_DX.py index bae7d54..8d2b08e 100644 --- a/taf/LT/LT_DX.py +++ b/taf/LT/LT_DX.py @@ -39,7 +39,7 @@ def create(self, runner: LT_Runner): end as ADJDCTN_DT , case when trim(upper(dgns_type_cd)) in {tuple(TAF_Metadata.DGNS_TYPE_CD_values)} then trim(upper(dgns_type_cd)) else NULL end as DGNS_TYPE_CD ,DGNS_SQNC_NUM - ,{ TAF_Closure.var_set_type2('DGNS_CD_IND', 0, cond1='1', cond2='2', cond3='3') } + ,{ TAF_Closure.var_set_type2('DGNS_CD_IND', 0, cond1='1', cond2='2') } ,{ TAF_Closure.var_set_type1('DGNS_CD') } ,{ TAF_Closure.var_set_type4('DGNS_POA_IND', 'YES', cond1='Y', cond2='N', cond3='U', cond4='W', cond5='1') } ,from_utc_timestamp(current_timestamp(), 'EST') as REC_ADD_TS From 03399c7a76cb458fa3421571b19f8e3c6cea7958 Mon Sep 17 00:00:00 2001 From: a-pfeiffer Date: Thu, 7 Aug 2025 08:06:36 -0400 Subject: [PATCH 3/4] DBDAART-15350 - OT - Removed "3" as a valid value from DGNS_IND fields in OTH and OT_DX. --- taf/OT/OTH.py | 4 ++-- taf/OT/OT_DX.py | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/taf/OT/OTH.py b/taf/OT/OTH.py index fe1ff09..9c6607f 100644 --- a/taf/OT/OTH.py +++ b/taf/OT/OTH.py @@ -83,10 +83,10 @@ def create(self, runner: OT_Runner): , { TAF_Closure.var_set_type1('MDCR_BENE_ID') } , { TAF_Closure.var_set_type2('HLTH_CARE_ACQRD_COND_CD', 0, cond1='0', cond2='1') } , { TAF_Closure.var_set_fills('DGNS_1_CD', cond1='0', cond2='8', cond3='9', cond4='#') } - , { TAF_Closure.var_set_type2('DGNS_1_CD_IND', 0, cond1='1', cond2='2', cond3='3') } + , { TAF_Closure.var_set_type2('DGNS_1_CD_IND', 0, cond1='1', cond2='2') } , DGNS_POA_1_CD_IND , { TAF_Closure.var_set_fills('DGNS_2_CD', cond1='0', cond2='8', cond3='9', cond4='#') } - , { TAF_Closure.var_set_type2('DGNS_2_CD_IND', 0, cond1='1', cond2='2', cond3='3') } + , { TAF_Closure.var_set_type2('DGNS_2_CD_IND', 0, cond1='1', cond2='2') } , DGNS_POA_2_CD_IND , { TAF_Closure.var_set_type1('SRVC_PLC_CD', upper=True, lpad=2) } , { TAF_Closure.var_set_type1('PRVDR_LCTN_ID') } diff --git a/taf/OT/OT_DX.py b/taf/OT/OT_DX.py index 4783e94..5fe90b5 100644 --- a/taf/OT/OT_DX.py +++ b/taf/OT/OT_DX.py @@ -40,7 +40,7 @@ def create(self, runner: OT_Runner): end as ADJDCTN_DT , case when trim(upper(dgns_type_cd)) in {tuple(TAF_Metadata.DGNS_TYPE_CD_values)} then trim(upper(dgns_type_cd)) else NULL end as DGNS_TYPE_CD , DGNS_SQNC_NUM - ,{ TAF_Closure.var_set_type2('DGNS_CD_IND', 0, cond1='1', cond2='2', cond3='3') } + ,{ TAF_Closure.var_set_type2('DGNS_CD_IND', 0, cond1='1', cond2='2') } ,DGNS_CD ,from_utc_timestamp(current_timestamp(), 'EST') as REC_ADD_TS ,from_utc_timestamp(current_timestamp(), 'EST') as REC_UPDT_TS --this must be equal to REC_ADD_TS for CCW pipeline From ac765259f16516b041e6447957b60f23c72fe26e Mon Sep 17 00:00:00 2001 From: a-pfeiffer Date: Thu, 7 Aug 2025 08:23:03 -0400 Subject: [PATCH 4/4] DBDAART-15350 - Removed "3" as a valid value in DGNS_CD_IND in RX_DX. --- taf/RX/RX_DX.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/taf/RX/RX_DX.py b/taf/RX/RX_DX.py index 76d0257..7b6e21f 100644 --- a/taf/RX/RX_DX.py +++ b/taf/RX/RX_DX.py @@ -39,7 +39,7 @@ def create(self, runner: RX_Runner): end as ADJDCTN_DT ,{ TAF_Closure.var_set_type4('DGNS_TYPE_CD', 'YES', cond1='A', cond2='D', cond3='E', cond4='O', cond5='P', cond6='R') } , DGNS_SQNC_NUM - ,{ TAF_Closure.var_set_type2('DGNS_CD_IND', 0, cond1='1', cond2='2', cond3='3') } + ,{ TAF_Closure.var_set_type2('DGNS_CD_IND', 0, cond1='1', cond2='2') } ,DGNS_CD ,from_utc_timestamp(current_timestamp(), 'EST') as REC_ADD_TS ,from_utc_timestamp(current_timestamp(), 'EST') as REC_UPDT_TS --this must be equal to REC_ADD_TS for CCW pipeline