Add tests for streams on DYNAMIC_TABLE

littleK0i · littleK0i · commit 4b0747809ee7 · 2026-01-21T12:13:33.000Z
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -1,5 +1,11 @@
 # Changelog
 
+## [0.62.1] - 2026-01-21
+
+- Added `DYNAMIC_TABLE` support for streams (thanks to @nigel-gott).
+- Added grant check for share access roles. Grant should be restored when underlying inbound share was dropped and re-created.
+- Prevented reset of `WORKSPACE_USER_SETTINGS` user parameter if it was not specified in config. We have to wait for documentation describing this parameter in order to make final decision.
+
 ## [0.62.0] - 2026-01-13
 
 - Added `application_roles` parameter form `BUSINESS_ROLE` object type. It is now possible to grant application roles directly to business roles. Env prefix is currently not supported, applications are supposed to be managed via different means for now.
diff --git a/snowddl/version.py b/snowddl/version.py
@@ -1 +1 @@
-__version__ = "0.62.0"
+__version__ = "0.62.1"
diff --git a/test/_config/step1/db1/sc1/dynamic_table/str006_dt1.yaml b/test/_config/step1/db1/sc1/dynamic_table/str006_dt1.yaml
@@ -0,0 +1,6 @@
+text: |-
+  SELECT id, name
+  FROM ${{ env_prefix }}db1.sc1.str006_tb1
+
+warehouse: str006_wh1
+target_lag: 1 hour
diff --git a/test/_config/step1/db1/sc1/params.yaml b/test/_config/step1/db1/sc1/params.yaml
@@ -12,4 +12,5 @@ owner_warehouse_usage:
   - mp001_wh1
   - pp001_wh1
   - rp001_wh1
+  - str006_wh1
   - ts001_wh1
diff --git a/test/_config/step1/db1/sc1/stream/str006_str1.yaml b/test/_config/step1/db1/sc1/stream/str006_str1.yaml
@@ -0,0 +1,3 @@
+object_type: DYNAMIC_TABLE
+object_name: str006_dt1
+comment: abc
diff --git a/test/_config/step1/db1/sc1/table/str006_tb1.yaml b/test/_config/step1/db1/sc1/table/str006_tb1.yaml
@@ -0,0 +1,5 @@
+columns:
+  id: NUMBER(10,0)
+  name: VARCHAR(255)
+
+change_tracking: true
diff --git a/test/_config/step1/warehouse.yaml b/test/_config/step1/warehouse.yaml
@@ -40,6 +40,9 @@ pp001_wh1:
 rp001_wh1:
   size: XSMALL
 
+str006_wh1:
+  size: XSMALL
+
 ts001_wh1:
   size: XSMALL
 
diff --git a/test/_config/step2/db1/sc1/dynamic_table/str006_dt1.yaml b/test/_config/step2/db1/sc1/dynamic_table/str006_dt1.yaml
@@ -0,0 +1,6 @@
+text: |-
+  SELECT id, name
+  FROM ${{ env_prefix }}db1.sc1.str006_tb1
+
+warehouse: str006_wh1
+target_lag: 1 hour
diff --git a/test/_config/step2/db1/sc1/params.yaml b/test/_config/step2/db1/sc1/params.yaml
@@ -11,3 +11,4 @@ owner_warehouse_usage:
   - mp001_wh1
   - pp001_wh1
   - rp001_wh1
+  - str006_wh1
diff --git a/test/_config/step2/db1/sc1/stream/str006_str1.yaml b/test/_config/step2/db1/sc1/stream/str006_str1.yaml
@@ -0,0 +1,3 @@
+object_type: DYNAMIC_TABLE
+object_name: str006_dt1
+comment: cde
diff --git a/test/_config/step2/db1/sc1/table/str006_tb1.yaml b/test/_config/step2/db1/sc1/table/str006_tb1.yaml
@@ -0,0 +1,5 @@
+columns:
+  id: NUMBER(10,0)
+  name: VARCHAR(255)
+
+change_tracking: true
diff --git a/test/_config/step2/warehouse.yaml b/test/_config/step2/warehouse.yaml
@@ -43,6 +43,9 @@ pp001_wh1:
 rp001_wh1:
   size: XSMALL
 
+str006_wh1:
+  size: XSMALL
+
 us001_wh1:
   size: XSMALL
 
diff --git a/test/stream/str006.py b/test/stream/str006.py
@@ -0,0 +1,20 @@
+def test_step1(helper):
+    stream_show = helper.show_stream("db1", "sc1", "str006_str1")
+
+    assert stream_show["source_type"] == "Dynamic Table"
+    assert stream_show["table_name"].endswith(".STR006_DT1")
+    assert stream_show["comment"] == "abc"
+
+
+def test_step2(helper):
+    stream_show = helper.show_stream("db1", "sc1", "str006_str1")
+
+    assert stream_show["source_type"] == "Dynamic Table"
+    assert stream_show["table_name"].endswith(".STR006_DT1")
+    assert stream_show["comment"] == "cde"
+
+
+def test_step3(helper):
+    stream_show = helper.show_stream("db1", "sc1", "str006_str1")
+
+    assert stream_show is None

Original file line number	Diff line number	Diff line change
`@@ -1 +1 @@`
`1`		`-__version__ = "0.62.0"`
	`1`	`+__version__ = "0.62.1"`
Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,3 @@`
	`1`	`+object_type: DYNAMIC_TABLE`
	`2`	`+object_name: str006_dt1`
	`3`	`+comment: abc`