diff --git a/scripts/jobs/parking/parking_defect_met_fail.py b/scripts/jobs/parking/parking_defect_met_fail.py index d6ed9237a..760bf2c55 100644 --- a/scripts/jobs/parking/parking_defect_met_fail.py +++ b/scripts/jobs/parking/parking_defect_met_fail.py @@ -43,14 +43,15 @@ def sparkSqlQuery(glueContext, query, mapping, transformation_ctx) -> DynamicFra # Script generated for node SQL SqlQuery33 = """ -/********************************************************************************* +/********************************************************************************************* Parking_Defect_MET_FAIL Temp SQL that formats the defcet managment records for Fail/Met 16/11/2022 - Create Query 15/01/2025 - found AND WHERE repair_date >= (??) removed AND -*********************************************************************************/ +20/01/2025 - length(ltrim(rtrim(reported_date))) > 0 to length(ltrim(rtrim(reported_date))) > 5 +**********************************************************************************************/ With Defect as ( SELECT reference_no, @@ -69,7 +70,7 @@ def sparkSqlQuery(glueContext, query, mapping, transformation_ctx) -> DynamicFra substr(repair_date, 7, 2)||'-'|| substr(repair_date, 9, 2) - When reported_date like '%/%'Then substr(repair_date, 7, 4)||'-'|| + When repair_date like '%/%'Then substr(repair_date, 7, 4)||'-'|| substr(repair_date, 4, 2)||'-'|| substr(repair_date, 1, 2) ELSE substr(cast(repair_date as string),1, 10)