Skip to content

Commit 2af2100

Browse files
committed
Fix tests
1 parent a3c53ea commit 2af2100

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
@@ -1888,13 +1888,16 @@ def test_snapshot_triggers(init_and_plan_context: t.Callable, mocker: MockerFixt
18881888
for k, v in actual_triggers.items()
18891889
if v.restatement_triggers
18901890
}
1891-
assert actual_triggers_name == {
1892-
waiter_revenue_by_day_name: [waiter_revenue_by_day_name, order_items_name],
1893-
order_items_name: [order_items_name],
1894-
'"memory"."sushi"."top_waiters"': [waiter_revenue_by_day_name],
1895-
'"memory"."sushi"."customer_revenue_by_day"': [order_items_name],
1896-
'"memory"."sushi"."customer_revenue_lifetime"': [order_items_name],
1897-
}
1891+
1892+
assert sorted(actual_triggers_name[waiter_revenue_by_day_name]) == sorted(
1893+
[waiter_revenue_by_day_name, order_items_name]
1894+
)
1895+
assert actual_triggers_name[order_items_name] == [order_items_name]
1896+
assert actual_triggers_name['"memory"."sushi"."top_waiters"'] == [waiter_revenue_by_day_name]
1897+
assert actual_triggers_name['"memory"."sushi"."customer_revenue_by_day"'] == [order_items_name]
1898+
assert actual_triggers_name['"memory"."sushi"."customer_revenue_lifetime"'] == [
1899+
order_items_name
1900+
]
18981901

18991902
# RUN: select and auto-restatement triggers
19001903
# User selects top_waiters and waiter_revenue_by_day, others added as auto-upstream
@@ -6751,13 +6754,13 @@ def plan_with_output(ctx: Context, environment: str):
67516754
assert "Differences from the `prod` environment" in output.stdout
67526755

67536756
assert (
6754-
"""MODEL (
6755-
name test.a,
6756-
+ owner test,
6757-
kind FULL
6758-
)
6759-
SELECT
6760-
- 5 AS col
6757+
"""MODEL (
6758+
name test.a,
6759+
+ owner test,
6760+
kind FULL
6761+
)
6762+
SELECT
6763+
- 5 AS col
67616764
+ 10 AS col"""
67626765
in output.stdout
67636766
)

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)