diff --git a/models/staging/shipping/base/base_shipping__sub_company_marking_connections.sql b/models/staging/shipping/base/base_shipping__sub_company_marking_connections.sql index 79dbd65..95766c2 100644 --- a/models/staging/shipping/base/base_shipping__sub_company_marking_connections.sql +++ b/models/staging/shipping/base/base_shipping__sub_company_marking_connections.sql @@ -3,19 +3,23 @@ WITH company_connections AS ( SELECT * FROM {{ source('src_shipping_mysql', 'company_connections') }} ), + -- LOGIC company_connections_rename AS ( SELECT - company_connections.id AS sub_company_marking_connection_id, - company_connections.invitee_id AS sub_company_id, + company_connections.id AS sub_company_marking_connection_id, + company_connections.invitee_id AS sub_company_id, company_connections.invitee_reference AS sub_company_marking_id, company_connections.status, - company_connections.created_at AS created_datetime, - company_connections.updated_at AS updated_datetime, + company_connections.is_credit_term AS is_credit_term_company, + company_connections.created_at AS created_datetime, + company_connections.updated_at AS updated_datetime, + '{{ modules.datetime.datetime.now(modules.pytz.timezone("Asia/Kuala_Lumpur")) }}' AS _dbt_ran_datetime FROM company_connections + ), @@ -30,6 +34,7 @@ final__base_shipping__sub_company_marking_connections AS ( -- dimensions status, + is_credit_term_company, -- measures @@ -41,6 +46,7 @@ final__base_shipping__sub_company_marking_connections AS ( _dbt_ran_datetime FROM company_connections_rename + ) SELECT * FROM final__base_shipping__sub_company_marking_connections \ No newline at end of file