Merged PR 2046: Guest Journey KPIs

Implements the following metrics:
- Guest Journey Created
- Guest Journey Started
- Guest Journey Completed
- Guest Journey Start Rate
- Guest Journey Completion Rate
- Guest Journey Incompletion Rate

A new model, namely int_core__mtd_guest_journey_metrics have been created, that mainly reads from int_core__verification_requests and the estimated start and complete dates logic.

Metrics are integrated into the already existing mtd_aggregated_metrics. Small changes here to allow multi-source via macro.

Finally, increased documentation regarding the aggregated model and added a exposure for the main_kpis dashboard.

I also took the opportunity to include the git ignore of the new package integrated in the previous PR.

To keep in mind: no change on the dashboard applies, the metrics should appear automatically at the moment this PR is merged & production is updated with the changes

Related work items: #17311

.gitignore

@@ -4,3 +4,4 @@ dbt_packages/
 logs/
 venv/
 *.dump
+package-lock.yml

models/intermediate/core/int_core__mtd_aggregated_metrics.sql

@@ -1,17 +1,26 @@
 {% set metrics = [
-    {'order_by': 1, 'metric': 'Created Bookings', 'value': 'created_bookings', 'previous_year_value': 'previous_year_created_bookings', 'relative_increment': 'relative_increment_created_bookings'},
+    {'source': 'int_core__mtd_booking_metrics', 'order_by': 1, 'metric': 'Created Bookings', 'value': 'created_bookings', 'previous_year_value': 'previous_year_created_bookings', 'relative_increment': 'relative_increment_created_bookings'},
-    {'order_by': 2, 'metric': 'Checkout Bookings', 'value': 'check_out_bookings', 'previous_year_value': 'previous_year_check_out_bookings', 'relative_increment': 'relative_increment_check_out_bookings'},
+    {'source': 'int_core__mtd_booking_metrics', 'order_by': 2, 'metric': 'Checkout Bookings', 'value': 'check_out_bookings', 'previous_year_value': 'previous_year_check_out_bookings', 'relative_increment': 'relative_increment_check_out_bookings'},
-    {'order_by': 3, 'metric': 'Listings Booked in Month', 'value': 'listings_booked_in_month', 'previous_year_value': 'previous_year_listings_booked_in_month', 'relative_increment': 'relative_increment_listings_booked_in_month'},
+    {'source': 'int_core__mtd_booking_metrics', 'order_by': 3, 'metric': 'Listings Booked in Month', 'value': 'listings_booked_in_month', 'previous_year_value': 'previous_year_listings_booked_in_month', 'relative_increment': 'relative_increment_listings_booked_in_month'},
-    {'order_by': 4, 'metric': 'Listings Booked in 6 Months', 'value': 'listings_booked_in_6_months', 'previous_year_value': 'previous_year_listings_booked_in_6_months', 'relative_increment': 'relative_increment_listings_booked_in_6_months'},
+    {'source': 'int_core__mtd_booking_metrics', 'order_by': 4, 'metric': 'Listings Booked in 6 Months', 'value': 'listings_booked_in_6_months', 'previous_year_value': 'previous_year_listings_booked_in_6_months', 'relative_increment': 'relative_increment_listings_booked_in_6_months'},
-    {'order_by': 5, 'metric': 'Listings Booked in 12 Months', 'value': 'listings_booked_in_12_months', 'previous_year_value': 'previous_year_listings_booked_in_12_months', 'relative_increment': 'relative_increment_listings_booked_in_12_months'},
+    {'source': 'int_core__mtd_booking_metrics', 'order_by': 5, 'metric': 'Listings Booked in 12 Months', 'value': 'listings_booked_in_12_months', 'previous_year_value': 'previous_year_listings_booked_in_12_months', 'relative_increment': 'relative_increment_listings_booked_in_12_months'},
-    {'order_by': 6, 'metric': 'Hosts Booked in Month', 'value': 'hosts_booked_in_month', 'previous_year_value': 'previous_year_hosts_booked_in_month', 'relative_increment': 'relative_increment_hosts_booked_in_month'},
+    {'source': 'int_core__mtd_booking_metrics', 'order_by': 6, 'metric': 'Hosts Booked in Month', 'value': 'hosts_booked_in_month', 'previous_year_value': 'previous_year_hosts_booked_in_month', 'relative_increment': 'relative_increment_hosts_booked_in_month'},
-    {'order_by': 7, 'metric': 'Hosts Booked in 6 Months', 'value': 'hosts_booked_in_6_months', 'previous_year_value': 'previous_year_hosts_booked_in_6_months', 'relative_increment': 'relative_increment_hosts_booked_in_6_months'},
+    {'source': 'int_core__mtd_booking_metrics', 'order_by': 7, 'metric': 'Hosts Booked in 6 Months', 'value': 'hosts_booked_in_6_months', 'previous_year_value': 'previous_year_hosts_booked_in_6_months', 'relative_increment': 'relative_increment_hosts_booked_in_6_months'},
-    {'order_by': 8, 'metric': 'Hosts Booked in 12 Months', 'value': 'hosts_booked_in_12_months', 'previous_year_value': 'previous_year_hosts_booked_in_12_months', 'relative_increment': 'relative_increment_hosts_booked_in_12_months'}
+    {'source': 'int_core__mtd_booking_metrics', 'order_by': 8, 'metric': 'Hosts Booked in 12 Months', 'value': 'hosts_booked_in_12_months', 'previous_year_value': 'previous_year_hosts_booked_in_12_months', 'relative_increment': 'relative_increment_hosts_booked_in_12_months'},
-] %}
+    {'source': 'int_core__mtd_guest_journey_metrics', 'order_by': 9, 'metric': 'Guest Journey Created', 'value': 'created_guest_journeys', 'previous_year_value': 'previous_year_created_guest_journeys', 'relative_increment': 'relative_increment_created_guest_journeys'},
+    {'source': 'int_core__mtd_guest_journey_metrics', 'order_by': 10, 'metric': 'Guest Journey Started', 'value': 'started_guest_journeys', 'previous_year_value': 'previous_year_started_guest_journeys', 'relative_increment': 'relative_increment_started_guest_journeys'},
+    {'source': 'int_core__mtd_guest_journey_metrics', 'order_by': 11, 'metric': 'Guest Journey Completed', 'value': 'completed_guest_journeys', 'previous_year_value': 'previous_year_completed_guest_journeys', 'relative_increment': 'relative_increment_completed_guest_journeys'},
+    {'source': 'int_core__mtd_guest_journey_metrics', 'order_by': 12, 'metric': 'Guest Journey Start Rate', 'value': 'start_rate_guest_journey', 'previous_year_value': 'previous_year_start_rate_guest_journey', 'relative_increment': 'relative_increment_start_rate_guest_journey'},
+    {'source': 'int_core__mtd_guest_journey_metrics', 'order_by': 13, 'metric': 'Guest Journey Completion Rate', 'value': 'completion_rate_guest_journey', 'previous_year_value': 'previous_year_completion_rate_guest_journey', 'relative_increment': 'relative_increment_completion_rate_guest_journey'},
+    {'source': 'int_core__mtd_guest_journey_metrics', 'order_by': 14, 'metric': 'Guest Journey Incompletion Rate', 'value': 'incompletion_rate_guest_journey', 'previous_year_value': 'previous_year_incompletion_rate_guest_journey', 'relative_increment': 'relative_increment_incompletion_rate_guest_journey'}
 
+] %}
 with
     int_core__mtd_booking_metrics as (
         select * from {{ ref("int_core__mtd_booking_metrics") }}
+    ),
+    int_core__mtd_guest_journey_metrics as (
+        select * from {{ ref("int_core__mtd_guest_journey_metrics") }} 
     )
 {% for metric in metrics %}
 select
@@ -27,6 +36,6 @@ select
     {{ metric.value }} as value,
     {{ metric.previous_year_value }} as previous_year_value,
     {{ metric.relative_increment }} as relative_increment
-from int_core__mtd_booking_metrics
+from {{ metric.source }}
 {% if not loop.last %}union all{% endif %}
 {% endfor %}

models/intermediate/core/int_core__mtd_guest_journey_metrics.sql

@@ -0,0 +1,99 @@
+/*
+This model provides Month-To-Date (MTD) based on Guest Journey metrics.
+
+*/
+{{ config(materialized="table", unique_key="date") }}
+with
+    int_core__verification_requests as (select * from {{ ref("int_core__verification_requests") }}),
+    int_dates_mtd as (select * from {{ ref("int_dates_mtd") }}),
+
+    -- Created Guest Journeys MTD --
+    created_year_month as (
+        select d.date, count(distinct vr.id_verification_request) as created_guest_journeys
+        from int_dates_mtd d
+        inner join
+            int_core__verification_requests vr
+            on extract(year from vr.created_date_utc) = d.year
+            and extract(month from vr.created_date_utc) = d.month
+            and extract(day from vr.created_date_utc) <= d.day
+        group by 1
+    ),
+    -- Started Guest Journeys MTD --
+    started_year_month as (
+        select d.date, count(distinct vr.id_verification_request) as started_guest_journeys
+        from int_dates_mtd d
+        inner join
+            int_core__verification_requests vr
+            on extract(year from vr.verification_estimated_started_date_utc) = d.year
+            and extract(month from vr.verification_estimated_started_date_utc) = d.month
+            and extract(day from vr.verification_estimated_started_date_utc) <= d.day
+        group by 1
+    ),
+    -- Completed Guest Journeys MTD --
+    completed_year_month as (
+        select d.date, count(distinct vr.id_verification_request) as completed_guest_journeys
+        from int_dates_mtd d
+        inner join
+            int_core__verification_requests vr
+            on extract(year from vr.verification_estimated_completed_date_utc) = d.year
+            and extract(month from vr.verification_estimated_completed_date_utc) = d.month
+            and extract(day from vr.verification_estimated_completed_date_utc) <= d.day
+        group by 1
+    ),
+    -- Final aggregation of subqueries + rates computation --
+    main_kpi as (
+    select 
+    	d.year,
+    	d.month,
+    	d.day,
+    	d.date,
+    	d.is_end_of_month,
+    	d.is_current_month,
+    	cym.created_guest_journeys,
+    	sym.started_guest_journeys,
+    	coym.completed_guest_journeys,
+    	cast(sym.started_guest_journeys as decimal)/cym.created_guest_journeys as start_rate_guest_journey,
+    	cast(coym.completed_guest_journeys as decimal)/sym.started_guest_journeys as completion_rate_guest_journey,
+    	1-cast(coym.completed_guest_journeys as decimal)/sym.started_guest_journeys as incompletion_rate_guest_journey
+    from int_dates_mtd d 
+    left join created_year_month cym on d.date = cym.date
+    left join started_year_month sym on d.date = sym.date
+    left join completed_year_month coym on d.date = coym.date
+    )
+-- Pivoting to get previous year for each line & computing relative increment
+-- (rel_incr) --
+select
+    a.year,
+    a.month,
+    a.day,
+    a.is_end_of_month,
+    a.is_current_month,
+    a.date,
+    b.date as previous_year_date,
+    a.created_guest_journeys,
+    b.created_guest_journeys as previous_year_created_guest_journeys,
+    cast(a.created_guest_journeys as decimal) / b.created_guest_journeys
+    - 1 as relative_increment_created_guest_journeys,
+    a.started_guest_journeys,
+    b.started_guest_journeys as previous_year_started_guest_journeys,
+    cast(a.started_guest_journeys as decimal) / b.started_guest_journeys
+    - 1 as relative_increment_started_guest_journeys,
+    a.completed_guest_journeys,
+    b.completed_guest_journeys as previous_year_completed_guest_journeys,
+    cast(a.completed_guest_journeys as decimal) / b.completed_guest_journeys
+    - 1 as relative_increment_completed_guest_journeys,
+    a.start_rate_guest_journey,
+    b.start_rate_guest_journey as previous_year_start_rate_guest_journey,
+    cast(a.start_rate_guest_journey as decimal) / b.start_rate_guest_journey
+    - 1 as relative_increment_start_rate_guest_journey,
+    a.completion_rate_guest_journey,
+    b.completion_rate_guest_journey as previous_year_completion_rate_guest_journey,
+    cast(a.completion_rate_guest_journey as decimal) / b.completion_rate_guest_journey
+    - 1 as relative_increment_completion_rate_guest_journey,
+    a.incompletion_rate_guest_journey,
+    b.incompletion_rate_guest_journey as previous_year_incompletion_rate_guest_journey,
+    cast(a.incompletion_rate_guest_journey as decimal) / b.incompletion_rate_guest_journey
+    - 1 as relative_increment_incompletion_rate_guest_journey
+from main_kpi a
+left join main_kpi b on a.month = b.month and a.year = b.year + 1
+where (a.is_end_of_month = 1 or (a.is_current_month = 1 and a.day = b.day))

models/intermediate/core/schema.yaml

@@ -205,11 +205,36 @@ models:
         tests:
           - not_null
 
+      - name: previous_year_date
+        data_type: date
+        description: |
+          corresponds to the date of the previous year, with respect to the field date. 
+          It comes from int_dates_mtd logic. It's only displayed for information purposes,
+          should not be needed for reporting.
+
       - name: metric
         data_type: text
         description: name of the business metric.
         tests:
           - not_null
+      
+      - name: value
+        data_type: numeric 
+        description: | 
+          numeric value (integer or decimal) that corresponds to the MTD computation of the metric
+          at a given date.
+
+      - name: previous_year_value
+        data_type: numeric 
+        description: | 
+          numeric value (integer or decimal) that corresponds to the MTD computation of the metric
+          on the previous year at a given date.
+
+      - name: relative_increment
+        data_type: numeric 
+        description: | 
+          numeric value that corresponds to the relative increment between value and previous year value,
+          following the computation: value / previous_year_value - 1.
 
   - name: int_core__verification_request_completeness
     description: |

models/reporting/exposures.yaml

@@ -95,3 +95,22 @@ exposures:
     owner:
       name: Pablo Martin
       email: pablo.martin@superhog.com
+
+  - name: main_kpis
+    label: Main Business KPIs
+    type: dashboard
+    maturity: medium
+    url: https://app.powerbi.com/links/ynCnuqVPTr?ctid=862842df-2998-4826-bea9-b726bc01d3a7&pbi_source=linkShare&bookmarkGuid=81e69a3e-90dc-46d7-b313-ba55ca611945
+    description: |
+      A PBI report showcasing the main business KPIs of our company.
+      
+      Includes multiple high-level metrics updated in a daily basis,
+      ensuring both a Month-to-date comprehension of our business and
+      a view on historic values on a month-by-month approach
+
+    depends_on:
+      - ref('core__mtd_aggregated_metrics')
+
+    owner:
+      name: Oriol Roqué
+      email: oriol.roque@superhog.com