From a5968114043e6d4f35b15aca2e43d4d82db3b6c6 Mon Sep 17 00:00:00 2001 From: Yam ZhengLim Date: Mon, 17 Jul 2023 05:16:11 +0000 Subject: [PATCH] Update company_adds increamental bug --- .../base/base_exchange__company_addresses.sql | 26 +------------------ 1 file changed, 1 insertion(+), 25 deletions(-) diff --git a/models/staging/exchange/base/base_exchange__company_addresses.sql b/models/staging/exchange/base/base_exchange__company_addresses.sql index a828656..de2a9ec 100644 --- a/models/staging/exchange/base/base_exchange__company_addresses.sql +++ b/models/staging/exchange/base/base_exchange__company_addresses.sql @@ -24,30 +24,6 @@ addresses_rename AS ( FROM addresses ), -remove_deleted_addresses AS ( - SELECT - * - - FROM addresses_rename - - WHERE - deleted_datetime IS NULL -), - -lastest_billing_and_non_billing_addresses AS ( - SELECT - *, - -- 1 will be latest updated address, rank by updated_at date - row_number() OVER - (PARTITION BY remove_deleted_addresses.company_id, remove_deleted_addresses.is_billing_address - ORDER BY remove_deleted_addresses.updated_datetime DESC) AS lastest_address_rank - - FROM remove_deleted_addresses - - QUALIFY - lastest_address_rank = 1 -), - -- FINAL final__base_exchange__company_addresses AS ( @@ -75,7 +51,7 @@ final__base_exchange__company_addresses AS ( -- metadata _dbt_ran_datetime - FROM lastest_billing_and_non_billing_addresses + FROM addresses_rename ) SELECT * FROM final__base_exchange__company_addresses \ No newline at end of file