Skip to content

Commit d105471

Browse files
committed
Fix tests
1 parent 46dbc3e commit d105471

2 files changed

Lines changed: 27 additions & 10 deletions

File tree

tests/core/test_integration.py

Lines changed: 21 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -1950,13 +1950,16 @@ def test_snapshot_triggers(init_and_plan_context: t.Callable, mocker: MockerFixt
19501950
for k, v in actual_triggers.items()
19511951
if v.restatement_triggers
19521952
}
1953-
assert actual_triggers_name == {
1954-
waiter_revenue_by_day_name: [waiter_revenue_by_day_name, order_items_name],
1955-
order_items_name: [order_items_name],
1956-
'"memory"."sushi"."top_waiters"': [waiter_revenue_by_day_name],
1957-
'"memory"."sushi"."customer_revenue_by_day"': [order_items_name],
1958-
'"memory"."sushi"."customer_revenue_lifetime"': [order_items_name],
1959-
}
1953+
1954+
assert sorted(actual_triggers_name[waiter_revenue_by_day_name]) == sorted(
1955+
[waiter_revenue_by_day_name, order_items_name]
1956+
)
1957+
assert actual_triggers_name[order_items_name] == [order_items_name]
1958+
assert actual_triggers_name['"memory"."sushi"."top_waiters"'] == [waiter_revenue_by_day_name]
1959+
assert actual_triggers_name['"memory"."sushi"."customer_revenue_by_day"'] == [order_items_name]
1960+
assert actual_triggers_name['"memory"."sushi"."customer_revenue_lifetime"'] == [
1961+
order_items_name
1962+
]
19601963

19611964
# RUN: select and auto-restatement triggers
19621965
# User selects top_waiters and waiter_revenue_by_day, others added as auto-upstream
@@ -7110,7 +7113,17 @@ def plan_with_output(ctx: Context, environment: str):
71107113
assert "New environment `dev` will be created from `prod`" in output.stdout
71117114
assert "Differences from the `prod` environment" in output.stdout
71127115

7113-
assert "Directly Modified: test__dev.a" in output.stdout
7116+
assert (
7117+
"""MODEL (
7118+
name test.a,
7119+
+ owner test,
7120+
kind FULL
7121+
)
7122+
SELECT
7123+
- 5 AS col
7124+
+ 10 AS col"""
7125+
in output.stdout
7126+
)
71147127

71157128
# Case 6: Ensure that target environment and create_from environment are not the same
71167129
output = plan_with_output(ctx, "prod")

tests/core/test_scheduler.py

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

62-
assert compute_interval_params([orders, waiter_revenue], start=start_ds, end=end_ds) == {
62+
interval_params, _ = compute_interval_params(
63+
[orders, waiter_revenue], start=start_ds, end=end_ds
64+
)
65+
assert interval_params == {
6366
orders: [
6467
(to_timestamp(start_ds), to_timestamp("2022-02-06")),
6568
],
@@ -91,7 +94,8 @@ def test_interval_params_nonconsecutive(scheduler: Scheduler, orders: Snapshot):
9194

9295
orders.add_interval("2022-01-10", "2022-01-15")
9396

94-
assert compute_interval_params([orders], start=start_ds, end=end_ds) == {
97+
interval_params, _ = compute_interval_params([orders], start=start_ds, end=end_ds)
98+
assert interval_params == {
9599
orders: [
96100
(to_timestamp(start_ds), to_timestamp("2022-01-10")),
97101
(to_timestamp("2022-01-16"), to_timestamp("2022-02-06")),

0 commit comments

Comments
 (0)