Skip to content

Commit 43ffb98

Browse files
committed
Add test
1 parent d6ab2fb commit 43ffb98

2 files changed

Lines changed: 18 additions & 0 deletions

File tree

tests/dbt/test_manifest.py

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -113,6 +113,11 @@ def test_manifest_helper(caplog):
113113
assert sources["streaming.orders"].schema_ == "raw"
114114
assert sources["streaming.order_items"].table_name == "order_items"
115115
assert sources["streaming.order_items"].schema_ == "raw"
116+
assert sources["streaming.order_items"].freshness == {
117+
"error_after": {"count": 13, "period": "hour"},
118+
"filter": None,
119+
"warn_after": {"count": 12, "period": "hour"},
120+
}
116121

117122

118123
@pytest.mark.xdist_group("dbt_manifest")

tests/fixtures/dbt/sushi_test/models/schema.yml

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -9,8 +9,14 @@ models:
99
data_type: double
1010
- name: model_columns
1111
data_type: int
12+
freshness:
13+
warn_after: {count: 6, period: hour}
14+
error_after: {count: 7, period: hour}
1215
config:
1316
dialect: postgres
17+
freshness:
18+
warn_after: {count: 8, period: hour}
19+
error_after: {count: 9, period: hour}
1420
- name: waiters
1521
- name: waiter_as_customer_by_day
1622
- name: waiter_revenue_by_day
@@ -30,6 +36,13 @@ sources:
3036
- name: items
3137
- name: orders
3238
- name: order_items
39+
freshness:
40+
warn_after: {count: 10, period: hour}
41+
error_after: {count: 11, period: hour}
42+
config:
43+
freshness:
44+
warn_after: {count: 12, period: hour}
45+
error_after: {count: 13, period: hour}
3346

3447
- name: parquet_file
3548
meta:

0 commit comments

Comments
 (0)