counterweight/data-dwh-dbt-project
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Added business scope to models

Browse source
This commit is contained in:
Joaquin 2025-03-14 11:48:22 +01:00
parent 72118389d6
commit 89b3989d19
6 changed files with 82 additions and 24 deletions
Download patch file Download diff file Expand all files Collapse all files

46
models/intermediate/cross/int_monthly_aggregated_metrics_history_by_deal.sql
View file

@ -16,6 +16,9 @@ with
int_kpis__dimension_daily_accommodation as (
select * from {{ ref("int_kpis__dimension_daily_accommodation") }}
),
int_core__new_dash_deal_since_date as (
select * from {{ ref("int_core__new_dash_deal_since_date") }}
),
listings as (
select *
from {{ ref("int_kpis__agg_daily_listings") }}
@ -83,6 +86,20 @@ select
-- DEAL STATIC ATTRIBUTES --
ikdd.id_deal,
ikdd.client_type,
case
when ikdd.client_type = 'API'
then 'API'
when ikdd.client_type = 'PLATFORM'
then
case
when
icnddsd.id_deal is not null
and d.date >= icnddsd.min_user_in_new_dash_since_date_utc
then 'New Dash'
else 'Old Dash'
end
else 'UNSET'
end as business_scope,
ikdd.main_deal_name,
ikdd.has_active_pms,
ikdd.active_pms_list,
@ -166,8 +183,7 @@ select
as host_resolution_amount_paid_per_created_booking,
{{
return_capped_value(
"cast(host_resolutions.xero_host_resolution_payment_count as decimal)
/ created_bookings.created_bookings",
"cast(host_resolutions.xero_host_resolution_payment_count as decimal) / created_bookings.created_bookings",
-1,
1,
)
@ -234,17 +250,7 @@ select
) as revenue_retained_in_gbp,
{{
return_capped_value(
"nullif(
coalesce(guest_payments.total_guest_payments_in_gbp, 0)
+ coalesce(invoiced_revenue.xero_operator_net_fees_in_gbp, 0)
+ coalesce(invoiced_revenue.xero_apis_net_fees_in_gbp, 0)
+ coalesce(invoiced_revenue.xero_waiver_paid_back_to_host_in_gbp, 0),
0) /
nullif(
coalesce(guest_payments.total_guest_payments_in_gbp, 0)
+ coalesce(invoiced_revenue.xero_operator_net_fees_in_gbp, 0)
+ coalesce(invoiced_revenue.xero_apis_net_fees_in_gbp, 0),
0)",
"nullif( coalesce(guest_payments.total_guest_payments_in_gbp, 0) + coalesce(invoiced_revenue.xero_operator_net_fees_in_gbp, 0) + coalesce(invoiced_revenue.xero_apis_net_fees_in_gbp, 0) + coalesce(invoiced_revenue.xero_waiver_paid_back_to_host_in_gbp, 0), 0) / nullif( coalesce(guest_payments.total_guest_payments_in_gbp, 0) + coalesce(invoiced_revenue.xero_operator_net_fees_in_gbp, 0) + coalesce(invoiced_revenue.xero_apis_net_fees_in_gbp, 0), 0)",
-1,
1,
)
@ -262,17 +268,7 @@ select
) as revenue_retained_post_resolutions_in_gbp,
{{
return_capped_value(
"nullif(
coalesce(guest_payments.total_guest_payments_in_gbp, 0)
+ coalesce(invoiced_revenue.xero_operator_net_fees_in_gbp, 0)
+ coalesce(invoiced_revenue.xero_apis_net_fees_in_gbp, 0)
+ coalesce(invoiced_revenue.xero_waiver_paid_back_to_host_in_gbp, 0)
+ coalesce(host_resolutions.xero_host_resolution_amount_paid_in_gbp, 0),
0) /
nullif(coalesce(guest_payments.total_guest_payments_in_gbp, 0)
+ coalesce(invoiced_revenue.xero_operator_net_fees_in_gbp, 0)
+ coalesce(invoiced_revenue.xero_apis_net_fees_in_gbp, 0),
0)",
"nullif( coalesce(guest_payments.total_guest_payments_in_gbp, 0) + coalesce(invoiced_revenue.xero_operator_net_fees_in_gbp, 0) + coalesce(invoiced_revenue.xero_apis_net_fees_in_gbp, 0) + coalesce(invoiced_revenue.xero_waiver_paid_back_to_host_in_gbp, 0) + coalesce(host_resolutions.xero_host_resolution_amount_paid_in_gbp, 0), 0) / nullif(coalesce(guest_payments.total_guest_payments_in_gbp, 0) + coalesce(invoiced_revenue.xero_operator_net_fees_in_gbp, 0) + coalesce(invoiced_revenue.xero_apis_net_fees_in_gbp, 0), 0)",
-1,
1,
)
@ -331,3 +327,5 @@ left join
host_resolutions
on d.date = host_resolutions.end_date
and d.dimension_value = host_resolutions.dimension_value
left join
int_core__new_dash_deal_since_date as icnddsd on ikdd.id_deal = icnddsd.id_deal

6
models/intermediate/cross/int_monthly_aggregated_metrics_history_by_deal_by_time_window.sql
View file

@ -13,6 +13,7 @@ with
date,
id_deal,
client_type,
business_scope,
main_deal_name,
has_active_pms,
active_pms_list,
@ -128,6 +129,7 @@ with
date,
id_deal,
client_type,
business_scope,
main_deal_name,
has_active_pms,
active_pms_list,
@ -228,6 +230,7 @@ with
date,
id_deal,
client_type,
business_scope,
main_deal_name,
has_active_pms,
active_pms_list,
@ -328,6 +331,7 @@ with
date,
id_deal,
client_type,
business_scope,
main_deal_name,
has_active_pms,
active_pms_list,
@ -428,6 +432,7 @@ with
date,
id_deal,
client_type,
business_scope,
main_deal_name,
has_active_pms,
active_pms_list,
@ -551,6 +556,7 @@ select
-- Deal attributes
mabd.client_type,
mabd.business_scope,
mabd.main_deal_name,
mabd.has_active_pms,
mabd.active_pms_list,

26
models/intermediate/cross/schema.yml
View file

@ -365,6 +365,19 @@ models:
- PLATFORM
- API
- name: business_scope
data_type: string
description: |
Business scope identifying the metric source.
data_tests:
- not_null
- accepted_values:
values:
- "Old Dash"
- "New Dash"
- "API"
- "UNSET"
- name: main_deal_name
data_type: string
description: |
@ -1548,6 +1561,19 @@ models:
- PLATFORM
- API
- name: business_scope
data_type: string
description: |
Business scope identifying the metric source.
data_tests:
- not_null
- accepted_values:
values:
- "Old Dash"
- "New Dash"
- "API"
- "UNSET"
- name: metric_from_date
data_type: date
description: |