diff --git a/dev/workflow/TK_Cust/tk_api_1/scrm_contact_lastupdated/S98_S_scrm_contact_lastupdated.sql b/dev/workflow/TK_Cust/tk_api_1/scrm_contact_lastupdated/S98_S_scrm_contact_lastupdated.sql index ac61d1d..6ee7b10 100644 --- a/dev/workflow/TK_Cust/tk_api_1/scrm_contact_lastupdated/S98_S_scrm_contact_lastupdated.sql +++ b/dev/workflow/TK_Cust/tk_api_1/scrm_contact_lastupdated/S98_S_scrm_contact_lastupdated.sql @@ -27,9 +27,9 @@ insert into p10_sa.S98_S_scrm_contact_lastupdated , date_join , etl_tx_dt from p00_tal.S98_S_scrm_contact_lastupdated - ; + ; delete from p12_sfull.S98_S_scrm_contact_lastupdated -; + where (id) in (select id from p10_sa.S98_S_scrm_contact_lastupdated) ; ; insert into p12_sfull.S98_S_scrm_contact_lastupdated ( id diff --git a/dev/workflow/TK_Cust/tk_api_1/scrm_contact_merge/S98_S_scrm_contact_merge.sql b/dev/workflow/TK_Cust/tk_api_1/scrm_contact_merge/S98_S_scrm_contact_merge.sql index 3ec47fb..8f3fb2c 100644 --- a/dev/workflow/TK_Cust/tk_api_1/scrm_contact_merge/S98_S_scrm_contact_merge.sql +++ b/dev/workflow/TK_Cust/tk_api_1/scrm_contact_merge/S98_S_scrm_contact_merge.sql @@ -47,9 +47,9 @@ insert into p10_sa.S98_S_scrm_contact_merge , target_id , etl_tx_dt from p00_tal.S98_S_scrm_contact_merge - ; + ; delete from p12_sfull.S98_S_scrm_contact_merge -; + where (id) in (select id from p10_sa.S98_S_scrm_contact_merge) ; ; insert into p12_sfull.S98_S_scrm_contact_merge ( merged_customer_id