Skip to content

Commit f53fb2e

Browse files
plypaulplypaul
committed
Update snapshots with DuckDB.
1 parent 47bc9f2 commit f53fb2e

File tree

66 files changed

+3320
-2375
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

66 files changed

+3320
-2375
lines changed

‎tests_metricflow/snapshots/test_cumulative_metric_rendering.py/SqlQueryPlan/DuckDB/test_derived_cumulative_metric_with_non_default_grains__plan0_optimized.sql‎

Lines changed: 50 additions & 34 deletions
Original file line numberDiff line numberDiff line change
@@ -4,44 +4,60 @@ docstring:
44
Test querying a derived metric with a cumulative input metric using non-default grains.
55
sql_engine: DuckDB
66
---
7-
-- Compute Metrics via Expressions
8-
SELECT
9-
metric_time__week
10-
, t2mr - 10 AS trailing_2_months_revenue_sub_10
11-
FROM (
12-
-- Re-aggregate Metric via Group By
7+
-- Read From CTE For node_id=cm_5
8+
WITH cm_4_cte AS (
9+
-- Compute Metrics via Expressions
10+
SELECT
11+
metric_time__week
12+
, txn_revenue AS t2mr
13+
FROM (
14+
-- Join Self Over Time Range
15+
-- Pass Only Elements: ['txn_revenue', 'metric_time__week', 'metric_time__day']
16+
-- Aggregate Measures
17+
SELECT
18+
subq_13.ds AS metric_time__day
19+
, DATE_TRUNC('week', subq_13.ds) AS metric_time__week
20+
, SUM(revenue_src_28000.revenue) AS txn_revenue
21+
FROM ***************************.mf_time_spine subq_13
22+
INNER JOIN
23+
***************************.fct_revenue revenue_src_28000
24+
ON
25+
(
26+
DATE_TRUNC('day', revenue_src_28000.created_at) <= subq_13.ds
27+
) AND (
28+
DATE_TRUNC('day', revenue_src_28000.created_at) > subq_13.ds - INTERVAL 2 month
29+
)
30+
GROUP BY
31+
subq_13.ds
32+
, DATE_TRUNC('week', subq_13.ds)
33+
) subq_16
34+
)
35+
36+
, cm_5_cte AS (
37+
-- Compute Metrics via Expressions
1338
SELECT
1439
metric_time__week
15-
, t2mr
40+
, t2mr - 10 AS trailing_2_months_revenue_sub_10
1641
FROM (
17-
-- Compute Metrics via Expressions
18-
-- Window Function for Metric Re-aggregation
42+
-- Re-aggregate Metric via Group By
1943
SELECT
2044
metric_time__week
21-
, AVG(txn_revenue) OVER (PARTITION BY metric_time__week) AS t2mr
45+
, t2mr
2246
FROM (
23-
-- Join Self Over Time Range
24-
-- Pass Only Elements: ['txn_revenue', 'metric_time__week', 'metric_time__day']
25-
-- Aggregate Measures
47+
-- Read From CTE For node_id=cm_4
48+
-- Window Function for Metric Re-aggregation
2649
SELECT
27-
subq_13.ds AS metric_time__day
28-
, DATE_TRUNC('week', subq_13.ds) AS metric_time__week
29-
, SUM(revenue_src_28000.revenue) AS txn_revenue
30-
FROM ***************************.mf_time_spine subq_13
31-
INNER JOIN
32-
***************************.fct_revenue revenue_src_28000
33-
ON
34-
(
35-
DATE_TRUNC('day', revenue_src_28000.created_at) <= subq_13.ds
36-
) AND (
37-
DATE_TRUNC('day', revenue_src_28000.created_at) > subq_13.ds - INTERVAL 2 month
38-
)
39-
GROUP BY
40-
subq_13.ds
41-
, DATE_TRUNC('week', subq_13.ds)
42-
) subq_16
43-
) subq_18
44-
GROUP BY
45-
metric_time__week
46-
, t2mr
47-
) subq_19
50+
metric_time__week
51+
, AVG(t2mr) OVER (PARTITION BY metric_time__week) AS t2mr
52+
FROM cm_4_cte cm_4_cte
53+
) subq_18
54+
GROUP BY
55+
metric_time__week
56+
, t2mr
57+
) subq_19
58+
)
59+
60+
SELECT
61+
metric_time__week AS metric_time__week
62+
, trailing_2_months_revenue_sub_10 AS trailing_2_months_revenue_sub_10
63+
FROM cm_5_cte cm_5_cte

‎tests_metricflow/snapshots/test_custom_granularity.py/SqlQueryPlan/DuckDB/test_derived_metric_with_custom_granularity__plan0_optimized.sql‎

Lines changed: 23 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -2,11 +2,8 @@ test_name: test_derived_metric_with_custom_granularity
22
test_filename: test_custom_granularity.py
33
sql_engine: DuckDB
44
---
5-
-- Compute Metrics via Expressions
6-
SELECT
7-
booking__ds__martian_day
8-
, booking_value * 0.05 / bookers AS booking_fees_per_booker
9-
FROM (
5+
-- Read From CTE For node_id=cm_9
6+
WITH cm_8_cte AS (
107
-- Metric Time Dimension 'ds'
118
-- Join to Custom Granularity Dataset
129
-- Pass Only Elements: ['booking_value', 'bookers', 'booking__ds__martian_day']
@@ -23,4 +20,24 @@ FROM (
2320
DATE_TRUNC('day', bookings_source_src_28000.ds) = subq_14.ds
2421
GROUP BY
2522
subq_14.martian_day
26-
) subq_18
23+
)
24+
25+
, cm_9_cte AS (
26+
-- Compute Metrics via Expressions
27+
SELECT
28+
booking__ds__martian_day
29+
, booking_value * 0.05 / bookers AS booking_fees_per_booker
30+
FROM (
31+
-- Read From CTE For node_id=cm_8
32+
SELECT
33+
booking__ds__martian_day
34+
, booking_value
35+
, bookers
36+
FROM cm_8_cte cm_8_cte
37+
) subq_18
38+
)
39+
40+
SELECT
41+
booking__ds__martian_day AS booking__ds__martian_day
42+
, booking_fees_per_booker AS booking_fees_per_booker
43+
FROM cm_9_cte cm_9_cte

‎tests_metricflow/snapshots/test_custom_granularity.py/SqlQueryPlan/DuckDB/test_multiple_metrics_with_custom_granularity__plan0_optimized.sql‎

Lines changed: 15 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -3,11 +3,7 @@ test_filename: test_custom_granularity.py
33
sql_engine: DuckDB
44
---
55
-- Combine Aggregated Outputs
6-
SELECT
7-
COALESCE(subq_17.metric_time__martian_day, subq_23.metric_time__martian_day) AS metric_time__martian_day
8-
, MAX(subq_17.bookings) AS bookings
9-
, MAX(subq_23.listings) AS listings
10-
FROM (
6+
WITH cm_4_cte AS (
117
-- Metric Time Dimension 'ds'
128
-- Join to Custom Granularity Dataset
139
-- Pass Only Elements: ['bookings', 'metric_time__martian_day']
@@ -29,8 +25,9 @@ FROM (
2925
subq_12.ds__day = subq_13.ds
3026
GROUP BY
3127
subq_13.martian_day
32-
) subq_17
33-
FULL OUTER JOIN (
28+
)
29+
30+
, cm_5_cte AS (
3431
-- Metric Time Dimension 'ds'
3532
-- Join to Custom Granularity Dataset
3633
-- Pass Only Elements: ['listings', 'metric_time__martian_day']
@@ -52,8 +49,16 @@ FULL OUTER JOIN (
5249
subq_18.ds__day = subq_19.ds
5350
GROUP BY
5451
subq_19.martian_day
55-
) subq_23
52+
)
53+
54+
SELECT
55+
COALESCE(cm_4_cte.metric_time__martian_day, cm_5_cte.metric_time__martian_day) AS metric_time__martian_day
56+
, MAX(cm_4_cte.bookings) AS bookings
57+
, MAX(cm_5_cte.listings) AS listings
58+
FROM cm_4_cte cm_4_cte
59+
FULL OUTER JOIN
60+
cm_5_cte cm_5_cte
5661
ON
57-
subq_17.metric_time__martian_day = subq_23.metric_time__martian_day
62+
cm_4_cte.metric_time__martian_day = cm_5_cte.metric_time__martian_day
5863
GROUP BY
59-
COALESCE(subq_17.metric_time__martian_day, subq_23.metric_time__martian_day)
64+
COALESCE(cm_4_cte.metric_time__martian_day, cm_5_cte.metric_time__martian_day)

‎tests_metricflow/snapshots/test_custom_granularity.py/SqlQueryPlan/DuckDB/test_offset_metric_with_custom_granularity__plan0_optimized.sql‎

Lines changed: 22 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -2,11 +2,8 @@ test_name: test_offset_metric_with_custom_granularity
22
test_filename: test_custom_granularity.py
33
sql_engine: DuckDB
44
---
5-
-- Compute Metrics via Expressions
6-
SELECT
7-
booking__ds__martian_day
8-
, bookings_5_days_ago AS bookings_5_day_lag
9-
FROM (
5+
-- Read From CTE For node_id=cm_5
6+
WITH cm_4_cte AS (
107
-- Join to Time Spine Dataset
118
-- Join to Custom Granularity Dataset
129
-- Pass Only Elements: ['bookings', 'booking__ds__martian_day']
@@ -32,4 +29,23 @@ FROM (
3229
subq_12.ds = subq_13.ds
3330
GROUP BY
3431
subq_13.martian_day
35-
) subq_17
32+
)
33+
34+
, cm_5_cte AS (
35+
-- Compute Metrics via Expressions
36+
SELECT
37+
booking__ds__martian_day
38+
, bookings_5_days_ago AS bookings_5_day_lag
39+
FROM (
40+
-- Read From CTE For node_id=cm_4
41+
SELECT
42+
booking__ds__martian_day
43+
, bookings_5_days_ago
44+
FROM cm_4_cte cm_4_cte
45+
) subq_17
46+
)
47+
48+
SELECT
49+
booking__ds__martian_day AS booking__ds__martian_day
50+
, bookings_5_day_lag AS bookings_5_day_lag
51+
FROM cm_5_cte cm_5_cte

‎tests_metricflow/snapshots/test_custom_granularity.py/SqlQueryPlan/DuckDB/test_offset_metric_with_custom_granularity_filter_not_in_group_by__plan0_optimized.sql‎

Lines changed: 22 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -2,11 +2,8 @@ test_name: test_offset_metric_with_custom_granularity_filter_not_in_group_by
22
test_filename: test_custom_granularity.py
33
sql_engine: DuckDB
44
---
5-
-- Compute Metrics via Expressions
6-
SELECT
7-
metric_time__day
8-
, bookings_5_days_ago AS bookings_5_day_lag
9-
FROM (
5+
-- Read From CTE For node_id=cm_5
6+
WITH cm_4_cte AS (
107
-- Constrain Output with WHERE
118
-- Pass Only Elements: ['bookings', 'metric_time__day']
129
-- Aggregate Measures
@@ -40,4 +37,23 @@ FROM (
4037
WHERE metric_time__martian_day = '2020-01-01'
4138
GROUP BY
4239
metric_time__day
43-
) subq_19
40+
)
41+
42+
, cm_5_cte AS (
43+
-- Compute Metrics via Expressions
44+
SELECT
45+
metric_time__day
46+
, bookings_5_days_ago AS bookings_5_day_lag
47+
FROM (
48+
-- Read From CTE For node_id=cm_4
49+
SELECT
50+
metric_time__day
51+
, bookings_5_days_ago
52+
FROM cm_4_cte cm_4_cte
53+
) subq_19
54+
)
55+
56+
SELECT
57+
metric_time__day AS metric_time__day
58+
, bookings_5_day_lag AS bookings_5_day_lag
59+
FROM cm_5_cte cm_5_cte

0 commit comments

Comments
 (0)