Skip to content

Commit ae1f7cc

Browse files
committed
docs(task): align stream schema in guard
1 parent bd12077 commit ae1f7cc

File tree

2 files changed

+3
-3
lines changed
  • docs
    • cn/guides/40-load-data/05-continuous-data-pipelines
    • en/guides/40-load-data/05-continuous-data-pipelines

2 files changed

+3
-3
lines changed

docs/cn/guides/40-load-data/05-continuous-data-pipelines/02-task.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -151,4 +151,4 @@ SELECT *
151151
FROM task_history('task_stream_merge', 5);
152152
```
153153

154-
只要 `STREAM_STATUS('<database>.<stream_name>')` 返回 TRUE,Task 就会运行;否则保持暂停,直到下一批增量到达。
154+
只要 `STREAM_STATUS('<database>.<stream_name>')` 返回 TRUE(例如 `task_demo.sensor_events_stream`,Task 就会运行;否则保持暂停,直到下一批增量到达。

docs/en/guides/40-load-data/05-continuous-data-pipelines/02-task.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -190,7 +190,7 @@ WHERE 1 = 0;
190190
CREATE OR REPLACE TASK task_stream_merge
191191
WAREHOUSE = 'etl_wh_small' -- replace with your warehouse
192192
SCHEDULE = 1 MINUTE
193-
WHEN STREAM_STATUS('doc_task_demo.sensor_events_stream') = TRUE
193+
WHEN STREAM_STATUS('task_demo.sensor_events_stream') = TRUE
194194
AS
195195
INSERT INTO sensor_events_latest
196196
SELECT *
@@ -211,5 +211,5 @@ SELECT *
211211
FROM task_history('task_stream_merge', 5);
212212
```
213213

214-
The task fires only when `STREAM_STATUS('<database>.<stream_name>')` returns `TRUE`. Always prefix the stream with its database (for example `doc_task_demo.sensor_events_stream`) so the task can resolve it regardless of the current schema, and use your own warehouse name in every `CREATE/ALTER TASK`.
214+
The task fires only when `STREAM_STATUS('<database>.<stream_name>')` returns `TRUE`. Always prefix the stream with its database (for example `task_demo.sensor_events_stream`) so the task can resolve it regardless of the current schema, and use your own warehouse name in every `CREATE/ALTER TASK`.
215215

0 commit comments

Comments
 (0)