Skip to content

Commit b645f63

Browse files
committed
Fix tests
1 parent 7761dd6 commit b645f63

2 files changed

Lines changed: 23 additions & 16 deletions

File tree

tests/core/test_integration.py

Lines changed: 17 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -1942,13 +1942,16 @@ def test_snapshot_triggers(init_and_plan_context: t.Callable, mocker: MockerFixt
19421942
for k, v in actual_triggers.items()
19431943
if v.restatement_triggers
19441944
}
1945-
assert actual_triggers_name == {
1946-
waiter_revenue_by_day_name: [waiter_revenue_by_day_name, order_items_name],
1947-
order_items_name: [order_items_name],
1948-
'"memory"."sushi"."top_waiters"': [waiter_revenue_by_day_name],
1949-
'"memory"."sushi"."customer_revenue_by_day"': [order_items_name],
1950-
'"memory"."sushi"."customer_revenue_lifetime"': [order_items_name],
1951-
}
1945+
1946+
assert sorted(actual_triggers_name[waiter_revenue_by_day_name]) == sorted(
1947+
[waiter_revenue_by_day_name, order_items_name]
1948+
)
1949+
assert actual_triggers_name[order_items_name] == [order_items_name]
1950+
assert actual_triggers_name['"memory"."sushi"."top_waiters"'] == [waiter_revenue_by_day_name]
1951+
assert actual_triggers_name['"memory"."sushi"."customer_revenue_by_day"'] == [order_items_name]
1952+
assert actual_triggers_name['"memory"."sushi"."customer_revenue_lifetime"'] == [
1953+
order_items_name
1954+
]
19521955

19531956
# RUN: select and auto-restatement triggers
19541957
# User selects top_waiters and waiter_revenue_by_day, others added as auto-upstream
@@ -7040,13 +7043,13 @@ def plan_with_output(ctx: Context, environment: str):
70407043
assert "Differences from the `prod` environment" in output.stdout
70417044

70427045
assert (
7043-
"""MODEL (
7044-
name test.a,
7045-
+ owner test,
7046-
kind FULL
7047-
)
7048-
SELECT
7049-
- 5 AS col
7046+
"""MODEL (
7047+
name test.a,
7048+
+ owner test,
7049+
kind FULL
7050+
)
7051+
SELECT
7052+
- 5 AS col
70507053
+ 10 AS col"""
70517054
in output.stdout
70527055
)

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)