Skip to content

Commit 0ecfb43

Browse files
committed
Fix tests
1 parent 4368aa2 commit 0ecfb43

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
@@ -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
@@ -6745,13 +6748,13 @@ def plan_with_output(ctx: Context, environment: str):
67456748
assert "Differences from the `prod` environment" in output.stdout
67466749

67476750
assert (
6748-
"""MODEL (
6749-
name test.a,
6750-
+ owner test,
6751-
kind FULL
6752-
)
6753-
SELECT
6754-
- 5 AS col
6751+
"""MODEL (
6752+
name test.a,
6753+
+ owner test,
6754+
kind FULL
6755+
)
6756+
SELECT
6757+
- 5 AS col
67556758
+ 10 AS col"""
67566759
in output.stdout
67576760
)

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)