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 中修改任务的依赖关系，这可能很有用。