Skip to content

Commit e8127db

Browse files
committed
Fix tests
1 parent f5b3abe commit e8127db

File tree

2 files changed

+23
-16
lines changed

2 files changed

+23
-16
lines changed

tests/core/test_integration.py

Lines changed: 17 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -1896,13 +1896,16 @@ def test_snapshot_triggers(init_and_plan_context: t.Callable, mocker: MockerFixt
18961896
for k, v in actual_triggers.items()
18971897
if v.restatement_triggers
18981898
}
1899-
assert actual_triggers_name == {
1900-
waiter_revenue_by_day_name: [waiter_revenue_by_day_name, order_items_name],
1901-
order_items_name: [order_items_name],
1902-
'"memory"."sushi"."top_waiters"': [waiter_revenue_by_day_name],
1903-
'"memory"."sushi"."customer_revenue_by_day"': [order_items_name],
1904-
'"memory"."sushi"."customer_revenue_lifetime"': [order_items_name],
1905-
}
1899+
1900+
assert sorted(actual_triggers_name[waiter_revenue_by_day_name]) == sorted(
1901+
[waiter_revenue_by_day_name, order_items_name]
1902+
)
1903+
assert actual_triggers_name[order_items_name] == [order_items_name]
1904+
assert actual_triggers_name['"memory"."sushi"."top_waiters"'] == [waiter_revenue_by_day_name]
1905+
assert actual_triggers_name['"memory"."sushi"."customer_revenue_by_day"'] == [order_items_name]
1906+
assert actual_triggers_name['"memory"."sushi"."customer_revenue_lifetime"'] == [
1907+
order_items_name
1908+
]
19061909

19071910
# RUN: select and auto-restatement triggers
19081911
# User selects top_waiters and waiter_revenue_by_day, others added as auto-upstream
@@ -6774,13 +6777,13 @@ def plan_with_output(ctx: Context, environment: str):
67746777
assert "Differences from the `prod` environment" in output.stdout
67756778

67766779
assert (
6777-
"""MODEL (
6778-
name test.a,
6779-
+ owner test,
6780-
kind FULL
6781-
)
6782-
SELECT
6783-
- 5 AS col
6780+
"""MODEL (
6781+
name test.a,
6782+
+ owner test,
6783+
kind FULL
6784+
)
6785+
SELECT
6786+
- 5 AS col
67846787
+ 10 AS col"""
67856788
in output.stdout
67866789
)

tests/core/test_scheduler.py

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -56,7 +56,10 @@ def test_interval_params(scheduler: Scheduler, sushi_context_fixed_date: Context
5656
start_ds = "2022-01-01"
5757
end_ds = "2022-02-05"
5858

59-
assert compute_interval_params([orders, waiter_revenue], start=start_ds, end=end_ds) == {
59+
interval_params, _ = compute_interval_params(
60+
[orders, waiter_revenue], start=start_ds, end=end_ds
61+
)
62+
assert interval_params == {
6063
orders: [
6164
(to_timestamp(start_ds), to_timestamp("2022-02-06")),
6265
],
@@ -88,7 +91,8 @@ def test_interval_params_nonconsecutive(scheduler: Scheduler, orders: Snapshot):
8891

8992
orders.add_interval("2022-01-10", "2022-01-15")
9093

91-
assert compute_interval_params([orders], start=start_ds, end=end_ds) == {
94+
interval_params, _ = compute_interval_params([orders], start=start_ds, end=end_ds)
95+
assert interval_params == {
9296
orders: [
9397
(to_timestamp(start_ds), to_timestamp("2022-01-10")),
9498
(to_timestamp("2022-01-16"), to_timestamp("2022-02-06")),

0 commit comments

Comments
 (0)