From f808d28d624bf0036e530054cdb1310184467359 Mon Sep 17 00:00:00 2001 From: Anna Saiapina Date: Mon, 25 Nov 2024 15:53:43 +0000 Subject: [PATCH] Add more alerting conditions --- definitions/staging/stg_csc_agent.sqlx | 16 +++++++++++----- 1 file changed, 11 insertions(+), 5 deletions(-) diff --git a/definitions/staging/stg_csc_agent.sqlx b/definitions/staging/stg_csc_agent.sqlx index e6889bd..4b3b0bd 100644 --- a/definitions/staging/stg_csc_agent.sqlx +++ b/definitions/staging/stg_csc_agent.sqlx @@ -4,7 +4,13 @@ config { schema: "pphe_five9_stg", assertions: { uniqueKey: ["UPDATE_USER", "CONFIRMATION_NO", "CHANGE_DATE", "UPDATE_TYPE"], - nonNull: ["UPDATE_USER", "CONFIRMATION_NO", "CHANGE_DATE", "UPDATE_TYPE"] + nonNull: ["UPDATE_USER", "CONFIRMATION_NO", "CHANGE_DATE", "UPDATE_TYPE"], + rowConditions: [ + 'UPDATE_TYPE_GROUP <> "NOT_MAPPED"', + 'REVENUE_GENERATING_YN <> "NOT_MAPPED"', + 'RESV_STATUS_ID <> 0', + 'UPDATE_TYPE_ID <> 0', + ] }, dependencies: ["csc_rev_data_freshness"], description: "All history data for csc revenue changes" @@ -24,7 +30,7 @@ csc_agent as ( cr.MARKET_DESC, cr.CONFIRMATION_NO, cr.RESV_STATUS, - ms.RESV_STATUS_ID, + COALESCE(ms.RESV_STATUS_ID, 0) as RESV_STATUS_ID, cr.ARRIVAL, cr.DEPARTURE, cr.UPDATE_USER, @@ -39,10 +45,10 @@ csc_agent as ( date(safe_cast(cr.CHANGE_DATE as timestamp)) DATE, extract(hour from safe_cast(cr.CHANGE_DATE as timestamp)) HOUR, cr.UPDATE_TYPE, - mu.UPDATE_TYPE_ID, + COALESCE(mu.UPDATE_TYPE_ID, 0) as UPDATE_TYPE_ID, mug.UPDATE_TYPE_GROUP_ID, - mugi.UPDATE_TYPE_GROUP, - mur.REVENUE_GENERATING_YN, + COALESCE(mugi.UPDATE_TYPE_GROUP, 'NOT_MAPPED') as UPDATE_TYPE_GROUP, + COALESCE(mur.REVENUE_GENERATING_YN, 'NOT_MAPPED') as REVENUE_GENERATING_YN, 1 as COUNTER, from csc_rev_deduplicated cr left join ${ref("pphe_five9_stg","stg_MAPPING_CSC_AGENT")} ca