Skip to content

Commit

Permalink
Merge pull request #973 from dbt-labs/fix-missing-trino-min-max-snaps…
Browse files Browse the repository at this point in the history
…hots

Add missing Trino snapshots
  • Loading branch information
tlento authored Jan 13, 2024
2 parents 1e38d13 + bd9c9f0 commit 217e064
Show file tree
Hide file tree
Showing 7 changed files with 328 additions and 1 deletion.
4 changes: 3 additions & 1 deletion metricflow/test/generate_snapshots.py
Original file line number Diff line number Diff line change
Expand Up @@ -151,7 +151,9 @@ def run_tests(test_configuration: MetricFlowTestConfiguration) -> None: # noqa:
engine_name = test_configuration.engine.value.lower()
os.environ["MF_TEST_ADAPTER_TYPE"] = engine_name
hatch_env = f"{engine_name}-env"
use_persistent_source_schema = test_configuration.engine != SqlEngine.POSTGRES
use_persistent_source_schema = (
test_configuration.engine != SqlEngine.POSTGRES and test_configuration.engine != SqlEngine.TRINO
)
run_command(
f"hatch -v run {hatch_env}:pytest -x -vv -n 4 "
f"--overwrite-snapshots"
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,73 @@
-- Calculate min and max
SELECT
MIN(subq_1.listing__country_latest) AS listing__country_latest__min
, MAX(subq_1.listing__country_latest) AS listing__country_latest__max
FROM (
-- Pass Only Elements:
-- ['listing__country_latest']
SELECT
subq_0.listing__country_latest
FROM (
-- Read Elements From Semantic Model 'listings_latest'
SELECT
1 AS listings
, listings_latest_src_10005.capacity AS largest_listing
, listings_latest_src_10005.capacity AS smallest_listing
, DATE_TRUNC('day', listings_latest_src_10005.created_at) AS ds__day
, DATE_TRUNC('week', listings_latest_src_10005.created_at) AS ds__week
, DATE_TRUNC('month', listings_latest_src_10005.created_at) AS ds__month
, DATE_TRUNC('quarter', listings_latest_src_10005.created_at) AS ds__quarter
, DATE_TRUNC('year', listings_latest_src_10005.created_at) AS ds__year
, EXTRACT(year FROM listings_latest_src_10005.created_at) AS ds__extract_year
, EXTRACT(quarter FROM listings_latest_src_10005.created_at) AS ds__extract_quarter
, EXTRACT(month FROM listings_latest_src_10005.created_at) AS ds__extract_month
, EXTRACT(day FROM listings_latest_src_10005.created_at) AS ds__extract_day
, EXTRACT(DAY_OF_WEEK FROM listings_latest_src_10005.created_at) AS ds__extract_dow
, EXTRACT(doy FROM listings_latest_src_10005.created_at) AS ds__extract_doy
, DATE_TRUNC('day', listings_latest_src_10005.created_at) AS created_at__day
, DATE_TRUNC('week', listings_latest_src_10005.created_at) AS created_at__week
, DATE_TRUNC('month', listings_latest_src_10005.created_at) AS created_at__month
, DATE_TRUNC('quarter', listings_latest_src_10005.created_at) AS created_at__quarter
, DATE_TRUNC('year', listings_latest_src_10005.created_at) AS created_at__year
, EXTRACT(year FROM listings_latest_src_10005.created_at) AS created_at__extract_year
, EXTRACT(quarter FROM listings_latest_src_10005.created_at) AS created_at__extract_quarter
, EXTRACT(month FROM listings_latest_src_10005.created_at) AS created_at__extract_month
, EXTRACT(day FROM listings_latest_src_10005.created_at) AS created_at__extract_day
, EXTRACT(DAY_OF_WEEK FROM listings_latest_src_10005.created_at) AS created_at__extract_dow
, EXTRACT(doy FROM listings_latest_src_10005.created_at) AS created_at__extract_doy
, listings_latest_src_10005.country AS country_latest
, listings_latest_src_10005.is_lux AS is_lux_latest
, listings_latest_src_10005.capacity AS capacity_latest
, DATE_TRUNC('day', listings_latest_src_10005.created_at) AS listing__ds__day
, DATE_TRUNC('week', listings_latest_src_10005.created_at) AS listing__ds__week
, DATE_TRUNC('month', listings_latest_src_10005.created_at) AS listing__ds__month
, DATE_TRUNC('quarter', listings_latest_src_10005.created_at) AS listing__ds__quarter
, DATE_TRUNC('year', listings_latest_src_10005.created_at) AS listing__ds__year
, EXTRACT(year FROM listings_latest_src_10005.created_at) AS listing__ds__extract_year
, EXTRACT(quarter FROM listings_latest_src_10005.created_at) AS listing__ds__extract_quarter
, EXTRACT(month FROM listings_latest_src_10005.created_at) AS listing__ds__extract_month
, EXTRACT(day FROM listings_latest_src_10005.created_at) AS listing__ds__extract_day
, EXTRACT(DAY_OF_WEEK FROM listings_latest_src_10005.created_at) AS listing__ds__extract_dow
, EXTRACT(doy FROM listings_latest_src_10005.created_at) AS listing__ds__extract_doy
, DATE_TRUNC('day', listings_latest_src_10005.created_at) AS listing__created_at__day
, DATE_TRUNC('week', listings_latest_src_10005.created_at) AS listing__created_at__week
, DATE_TRUNC('month', listings_latest_src_10005.created_at) AS listing__created_at__month
, DATE_TRUNC('quarter', listings_latest_src_10005.created_at) AS listing__created_at__quarter
, DATE_TRUNC('year', listings_latest_src_10005.created_at) AS listing__created_at__year
, EXTRACT(year FROM listings_latest_src_10005.created_at) AS listing__created_at__extract_year
, EXTRACT(quarter FROM listings_latest_src_10005.created_at) AS listing__created_at__extract_quarter
, EXTRACT(month FROM listings_latest_src_10005.created_at) AS listing__created_at__extract_month
, EXTRACT(day FROM listings_latest_src_10005.created_at) AS listing__created_at__extract_day
, EXTRACT(DAY_OF_WEEK FROM listings_latest_src_10005.created_at) AS listing__created_at__extract_dow
, EXTRACT(doy FROM listings_latest_src_10005.created_at) AS listing__created_at__extract_doy
, listings_latest_src_10005.country AS listing__country_latest
, listings_latest_src_10005.is_lux AS listing__is_lux_latest
, listings_latest_src_10005.capacity AS listing__capacity_latest
, listings_latest_src_10005.listing_id AS listing
, listings_latest_src_10005.user_id AS user
, listings_latest_src_10005.user_id AS listing__user
FROM ***************************.dim_listings_latest listings_latest_src_10005
) subq_0
GROUP BY
subq_0.listing__country_latest
) subq_1
Original file line number Diff line number Diff line change
@@ -0,0 +1,14 @@
-- Calculate min and max
SELECT
MIN(listing__country_latest) AS listing__country_latest__min
, MAX(listing__country_latest) AS listing__country_latest__max
FROM (
-- Read Elements From Semantic Model 'listings_latest'
-- Pass Only Elements:
-- ['listing__country_latest']
SELECT
country AS listing__country_latest
FROM ***************************.dim_listings_latest listings_latest_src_10005
GROUP BY
country
) subq_3
Original file line number Diff line number Diff line change
@@ -0,0 +1,105 @@
-- Calculate min and max
SELECT
MIN(subq_1.booking__paid_at__day) AS booking__paid_at__day__min
, MAX(subq_1.booking__paid_at__day) AS booking__paid_at__day__max
FROM (
-- Pass Only Elements:
-- ['booking__paid_at__day']
SELECT
subq_0.booking__paid_at__day
FROM (
-- Read Elements From Semantic Model 'bookings_source'
SELECT
1 AS bookings
, CASE WHEN is_instant THEN 1 ELSE 0 END AS instant_bookings
, bookings_source_src_10001.booking_value
, bookings_source_src_10001.booking_value AS max_booking_value
, bookings_source_src_10001.booking_value AS min_booking_value
, bookings_source_src_10001.guest_id AS bookers
, bookings_source_src_10001.booking_value AS average_booking_value
, bookings_source_src_10001.booking_value AS booking_payments
, CASE WHEN referrer_id IS NOT NULL THEN 1 ELSE 0 END AS referred_bookings
, bookings_source_src_10001.booking_value AS median_booking_value
, bookings_source_src_10001.booking_value AS booking_value_p99
, bookings_source_src_10001.booking_value AS discrete_booking_value_p99
, bookings_source_src_10001.booking_value AS approximate_continuous_booking_value_p99
, bookings_source_src_10001.booking_value AS approximate_discrete_booking_value_p99
, bookings_source_src_10001.is_instant
, DATE_TRUNC('day', bookings_source_src_10001.ds) AS ds__day
, DATE_TRUNC('week', bookings_source_src_10001.ds) AS ds__week
, DATE_TRUNC('month', bookings_source_src_10001.ds) AS ds__month
, DATE_TRUNC('quarter', bookings_source_src_10001.ds) AS ds__quarter
, DATE_TRUNC('year', bookings_source_src_10001.ds) AS ds__year
, EXTRACT(year FROM bookings_source_src_10001.ds) AS ds__extract_year
, EXTRACT(quarter FROM bookings_source_src_10001.ds) AS ds__extract_quarter
, EXTRACT(month FROM bookings_source_src_10001.ds) AS ds__extract_month
, EXTRACT(day FROM bookings_source_src_10001.ds) AS ds__extract_day
, EXTRACT(DAY_OF_WEEK FROM bookings_source_src_10001.ds) AS ds__extract_dow
, EXTRACT(doy FROM bookings_source_src_10001.ds) AS ds__extract_doy
, DATE_TRUNC('day', bookings_source_src_10001.ds_partitioned) AS ds_partitioned__day
, DATE_TRUNC('week', bookings_source_src_10001.ds_partitioned) AS ds_partitioned__week
, DATE_TRUNC('month', bookings_source_src_10001.ds_partitioned) AS ds_partitioned__month
, DATE_TRUNC('quarter', bookings_source_src_10001.ds_partitioned) AS ds_partitioned__quarter
, DATE_TRUNC('year', bookings_source_src_10001.ds_partitioned) AS ds_partitioned__year
, EXTRACT(year FROM bookings_source_src_10001.ds_partitioned) AS ds_partitioned__extract_year
, EXTRACT(quarter FROM bookings_source_src_10001.ds_partitioned) AS ds_partitioned__extract_quarter
, EXTRACT(month FROM bookings_source_src_10001.ds_partitioned) AS ds_partitioned__extract_month
, EXTRACT(day FROM bookings_source_src_10001.ds_partitioned) AS ds_partitioned__extract_day
, EXTRACT(DAY_OF_WEEK FROM bookings_source_src_10001.ds_partitioned) AS ds_partitioned__extract_dow
, EXTRACT(doy FROM bookings_source_src_10001.ds_partitioned) AS ds_partitioned__extract_doy
, DATE_TRUNC('day', bookings_source_src_10001.paid_at) AS paid_at__day
, DATE_TRUNC('week', bookings_source_src_10001.paid_at) AS paid_at__week
, DATE_TRUNC('month', bookings_source_src_10001.paid_at) AS paid_at__month
, DATE_TRUNC('quarter', bookings_source_src_10001.paid_at) AS paid_at__quarter
, DATE_TRUNC('year', bookings_source_src_10001.paid_at) AS paid_at__year
, EXTRACT(year FROM bookings_source_src_10001.paid_at) AS paid_at__extract_year
, EXTRACT(quarter FROM bookings_source_src_10001.paid_at) AS paid_at__extract_quarter
, EXTRACT(month FROM bookings_source_src_10001.paid_at) AS paid_at__extract_month
, EXTRACT(day FROM bookings_source_src_10001.paid_at) AS paid_at__extract_day
, EXTRACT(DAY_OF_WEEK FROM bookings_source_src_10001.paid_at) AS paid_at__extract_dow
, EXTRACT(doy FROM bookings_source_src_10001.paid_at) AS paid_at__extract_doy
, bookings_source_src_10001.is_instant AS booking__is_instant
, DATE_TRUNC('day', bookings_source_src_10001.ds) AS booking__ds__day
, DATE_TRUNC('week', bookings_source_src_10001.ds) AS booking__ds__week
, DATE_TRUNC('month', bookings_source_src_10001.ds) AS booking__ds__month
, DATE_TRUNC('quarter', bookings_source_src_10001.ds) AS booking__ds__quarter
, DATE_TRUNC('year', bookings_source_src_10001.ds) AS booking__ds__year
, EXTRACT(year FROM bookings_source_src_10001.ds) AS booking__ds__extract_year
, EXTRACT(quarter FROM bookings_source_src_10001.ds) AS booking__ds__extract_quarter
, EXTRACT(month FROM bookings_source_src_10001.ds) AS booking__ds__extract_month
, EXTRACT(day FROM bookings_source_src_10001.ds) AS booking__ds__extract_day
, EXTRACT(DAY_OF_WEEK FROM bookings_source_src_10001.ds) AS booking__ds__extract_dow
, EXTRACT(doy FROM bookings_source_src_10001.ds) AS booking__ds__extract_doy
, DATE_TRUNC('day', bookings_source_src_10001.ds_partitioned) AS booking__ds_partitioned__day
, DATE_TRUNC('week', bookings_source_src_10001.ds_partitioned) AS booking__ds_partitioned__week
, DATE_TRUNC('month', bookings_source_src_10001.ds_partitioned) AS booking__ds_partitioned__month
, DATE_TRUNC('quarter', bookings_source_src_10001.ds_partitioned) AS booking__ds_partitioned__quarter
, DATE_TRUNC('year', bookings_source_src_10001.ds_partitioned) AS booking__ds_partitioned__year
, EXTRACT(year FROM bookings_source_src_10001.ds_partitioned) AS booking__ds_partitioned__extract_year
, EXTRACT(quarter FROM bookings_source_src_10001.ds_partitioned) AS booking__ds_partitioned__extract_quarter
, EXTRACT(month FROM bookings_source_src_10001.ds_partitioned) AS booking__ds_partitioned__extract_month
, EXTRACT(day FROM bookings_source_src_10001.ds_partitioned) AS booking__ds_partitioned__extract_day
, EXTRACT(DAY_OF_WEEK FROM bookings_source_src_10001.ds_partitioned) AS booking__ds_partitioned__extract_dow
, EXTRACT(doy FROM bookings_source_src_10001.ds_partitioned) AS booking__ds_partitioned__extract_doy
, DATE_TRUNC('day', bookings_source_src_10001.paid_at) AS booking__paid_at__day
, DATE_TRUNC('week', bookings_source_src_10001.paid_at) AS booking__paid_at__week
, DATE_TRUNC('month', bookings_source_src_10001.paid_at) AS booking__paid_at__month
, DATE_TRUNC('quarter', bookings_source_src_10001.paid_at) AS booking__paid_at__quarter
, DATE_TRUNC('year', bookings_source_src_10001.paid_at) AS booking__paid_at__year
, EXTRACT(year FROM bookings_source_src_10001.paid_at) AS booking__paid_at__extract_year
, EXTRACT(quarter FROM bookings_source_src_10001.paid_at) AS booking__paid_at__extract_quarter
, EXTRACT(month FROM bookings_source_src_10001.paid_at) AS booking__paid_at__extract_month
, EXTRACT(day FROM bookings_source_src_10001.paid_at) AS booking__paid_at__extract_day
, EXTRACT(DAY_OF_WEEK FROM bookings_source_src_10001.paid_at) AS booking__paid_at__extract_dow
, EXTRACT(doy FROM bookings_source_src_10001.paid_at) AS booking__paid_at__extract_doy
, bookings_source_src_10001.listing_id AS listing
, bookings_source_src_10001.guest_id AS guest
, bookings_source_src_10001.host_id AS host
, bookings_source_src_10001.listing_id AS booking__listing
, bookings_source_src_10001.guest_id AS booking__guest
, bookings_source_src_10001.host_id AS booking__host
FROM ***************************.fct_bookings bookings_source_src_10001
) subq_0
GROUP BY
subq_0.booking__paid_at__day
) subq_1
Original file line number Diff line number Diff line change
@@ -0,0 +1,14 @@
-- Calculate min and max
SELECT
MIN(booking__paid_at__day) AS booking__paid_at__day__min
, MAX(booking__paid_at__day) AS booking__paid_at__day__max
FROM (
-- Read Elements From Semantic Model 'bookings_source'
-- Pass Only Elements:
-- ['booking__paid_at__day']
SELECT
DATE_TRUNC('day', paid_at) AS booking__paid_at__day
FROM ***************************.fct_bookings bookings_source_src_10001
GROUP BY
DATE_TRUNC('day', paid_at)
) subq_3
Loading

0 comments on commit 217e064

Please sign in to comment.