ALTER TASK

Introduced or updated: v1.2.371

ALTER TASK 语句用于修改现有的任务。

注意： 此功能仅在 Databend Cloud 中开箱即用。

语法

--- 暂停或恢复任务
ALTER TASK [ IF EXISTS ] <name> RESUME | SUSPEND

--- 更改任务设置
ALTER TASK [ IF EXISTS ] <name> SET
  [ WAREHOUSE = <string> ]
  [ SCHEDULE = { <number> MINUTE | <number> SECOND | USING CRON <expr> <time_zone> } ]
  [ SUSPEND_TASK_AFTER_NUM_FAILURES = <num ]
  [ ERROR_INTEGRATION = <string> ]
   [ <session_parameter> = <value> [ , <session_parameter> = <value> ... ] ]
  [ COMMENT = <string> ]

--- 更改任务 SQL
ALTER TASK [ IF EXISTS ] <name> MODIFY AS <sql>

--- 修改 DAG 中的前置条件和后置条件
ALTER TASK [ IF EXISTS ] <name> REMOVE AFTER <string> [ , <string> , ... ] | ADD AFTER <string> [ , <string> , ... ]
--- 允许更改任务执行的条件
ALTER TASK [ IF EXISTS ] <name> MODIFY WHEN <boolean_expr>

参数	描述
IF EXISTS	可选。如果指定，只有在同名任务已存在时才会更改任务。
name	任务的名称。这是一个必填字段。
RESUME \| SUSPEND	恢复或暂停任务。
SET	更改任务设置。详细参数描述可以在 Create Task 中找到。
MODIFY AS	更改任务 SQL。
REMOVE AFTER	从任务 DAG 中移除前置任务，任务将成为独立任务或根任务（如果没有剩余的前置任务）。
ADD AFTER	向前置任务 DAG 中添加前置任务。
MODIFY WHEN	更改任务执行的条件。

ALTER TASK IF EXISTS mytask SUSPEND;

此命令暂停名为 mytask 的任务（如果存在）。

ALTER TASK IF EXISTS mytask SET
  WAREHOUSE = 'new_warehouse'
  SCHEDULE = USING CRON '0 12 * * * *' 'UTC';

此示例更改 mytask 任务，将其计算集群更改为 new_warehouse，并将其计划更新为每天中午 UTC 时间运行。

ALTER TASK IF EXISTS mytask MODIFY 
AS
INSERT INTO new_table SELECT * FROM source_table;

在这里，mytask 执行的 SQL 语句被更改为将数据从 source_table 插入到 new_table 中。

ALTER TASK mytaskchild MODIFY WHEN STREAM_STATUS('stream3') = False;

在此示例中，我们正在修改 mytaskchild 任务以更改其 WHEN 条件。任务现在仅在 STREAM_STATUS 函数对 'stream3' 评估为 False 时运行。这意味着任务将在 'stream3' 不包含更改数据时执行。

ALTER TASK MyTask1 ADD AFTER 'task2', 'task3';

在此示例中，我们正在向 MyTask1 任务添加依赖关系。它现在将在 'task2' 和 'task3' 成功完成后运行。这会在任务的有向无环图 (DAG) 中创建依赖关系。

ALTER TASK MyTask1 REMOVE AFTER 'task2';

在这里，我们正在为 MyTask1 任务移除特定的依赖关系。它将不再在 'task2' 之后运行。如果您想在任务的 DAG 中修改任务的依赖关系，这可能很有用。