Skip to content

Commit a66524c

Browse files
committed
Fix tests
1 parent 1c7ca89 commit a66524c

File tree

2 files changed

+16
-9
lines changed

2 files changed

+16
-9
lines changed

tests/core/test_integration.py

Lines changed: 10 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1867,13 +1867,16 @@ def test_snapshot_triggers(init_and_plan_context: t.Callable, mocker: MockerFixt
18671867
for k, v in actual_triggers.items()
18681868
if v.restatement_triggers
18691869
}
1870-
assert actual_triggers_name == {
1871-
waiter_revenue_by_day_name: [waiter_revenue_by_day_name, order_items_name],
1872-
order_items_name: [order_items_name],
1873-
'"memory"."sushi"."top_waiters"': [waiter_revenue_by_day_name],
1874-
'"memory"."sushi"."customer_revenue_by_day"': [order_items_name],
1875-
'"memory"."sushi"."customer_revenue_lifetime"': [order_items_name],
1876-
}
1870+
1871+
assert sorted(actual_triggers_name[waiter_revenue_by_day_name]) == sorted(
1872+
[waiter_revenue_by_day_name, order_items_name]
1873+
)
1874+
assert actual_triggers_name[order_items_name] == [order_items_name]
1875+
assert actual_triggers_name['"memory"."sushi"."top_waiters"'] == [waiter_revenue_by_day_name]
1876+
assert actual_triggers_name['"memory"."sushi"."customer_revenue_by_day"'] == [order_items_name]
1877+
assert actual_triggers_name['"memory"."sushi"."customer_revenue_lifetime"'] == [
1878+
order_items_name
1879+
]
18771880

18781881
# RUN: select and auto-restatement triggers
18791882
# User selects top_waiters and waiter_revenue_by_day, others added as auto-upstream

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)