diff --git a/definitions/staging/stg_calls.sqlx b/definitions/staging/stg_calls.sqlx index d07eab7..fe83f5c 100644 --- a/definitions/staging/stg_calls.sqlx +++ b/definitions/staging/stg_calls.sqlx @@ -16,7 +16,8 @@ select *, OVER (PARTITION BY SESSION_ID, TIMESTAMP, DNIS) row_number from ${ref("pphe_five9_raw","calls_*")} -${ when(incremental(), `where _TABLE_SUFFIX = FORMAT_DATE('%Y%m%d',current_date("Europe/Amsterdam"))`) }) +where ABANDONED is not null +${ when(incremental(), `and _TABLE_SUFFIX = FORMAT_DATE('%Y%m%d',current_date("Europe/Amsterdam"))`) }) select DAY_OF_WEEK, CALL_ID, CAMPAIGN, @@ -27,7 +28,7 @@ select DAY_OF_WEEK, CALL_TIME, RING_TIME, TALK_TIME, - AFTER_CALL_WORK_TIME, + AFTER_CALL_WORK_TIME,-- ABANDONED, COALESCE(AGENT_GROUP, '0') AS AGENT_GROUP, CALLS,