Anna_Saiapina/five9
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Add more alerting conditions

Browse Source
This commit is contained in:
Anna Saiapina 2024-11-25 15:53:43 +00:00 committed by GCP Dataform
parent add6e94187
commit f808d28d62
1 changed files with 11 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
definitions/staging/stg_csc_agent.sqlx
View File

@ -4,7 +4,13 @@ config {
schema: "pphe_five9_stg", schema: "pphe_five9_stg",
assertions: { assertions: {
uniqueKey: ["UPDATE_USER", "CONFIRMATION_NO", "CHANGE_DATE", "UPDATE_TYPE"], 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"], dependencies: ["csc_rev_data_freshness"],
description: "All history data for csc revenue changes" description: "All history data for csc revenue changes"
@ -24,7 +30,7 @@ csc_agent as (
cr.MARKET_DESC, cr.MARKET_DESC,
cr.CONFIRMATION_NO, cr.CONFIRMATION_NO,
cr.RESV_STATUS, cr.RESV_STATUS,
ms.RESV_STATUS_ID, COALESCE(ms.RESV_STATUS_ID, 0) as RESV_STATUS_ID,
cr.ARRIVAL, cr.ARRIVAL,
cr.DEPARTURE, cr.DEPARTURE,
cr.UPDATE_USER, cr.UPDATE_USER,
@ -39,10 +45,10 @@ csc_agent as (
date(safe_cast(cr.CHANGE_DATE as timestamp)) DATE, date(safe_cast(cr.CHANGE_DATE as timestamp)) DATE,
extract(hour from safe_cast(cr.CHANGE_DATE as timestamp)) HOUR, extract(hour from safe_cast(cr.CHANGE_DATE as timestamp)) HOUR,
cr.UPDATE_TYPE, cr.UPDATE_TYPE,
mu.UPDATE_TYPE_ID, COALESCE(mu.UPDATE_TYPE_ID, 0) as UPDATE_TYPE_ID,
mug.UPDATE_TYPE_GROUP_ID, mug.UPDATE_TYPE_GROUP_ID,
mugi.UPDATE_TYPE_GROUP, COALESCE(mugi.UPDATE_TYPE_GROUP, 'NOT_MAPPED') as UPDATE_TYPE_GROUP,
mur.REVENUE_GENERATING_YN, COALESCE(mur.REVENUE_GENERATING_YN, 'NOT_MAPPED') as REVENUE_GENERATING_YN,
1 as COUNTER, 1 as COUNTER,
from csc_rev_deduplicated cr from csc_rev_deduplicated cr
left join ${ref("pphe_five9_stg","stg_MAPPING_CSC_AGENT")} ca left join ${ref("pphe_five9_stg","stg_MAPPING_CSC_AGENT")} ca