/update-pipeline-task

name: update-pipeline-task
description: |-
  修改已存在的集成管道任务配置（调度 / 通道 / 组件 / 基本信息），采用「先查后改、全量回写」模式。
  触发场景：修改管道任务调度周期 / cron / 重跑策略 / 优先级 / 上游依赖 / 资源组；修改并发数、脏数据上限、超时；修改 reader-writer 字段映射 / 过滤条件 / 分区表达式；修改后重新提交。
  触发词：修改管道任务、更新管道、修改调度配置、改 cron、修改同步任务、update-pipeline、修改并发、修改脏数据、修改字段映射、重新提交管道。
  关键限制：update-pipeline 是全量覆盖而非增量 patch——node-info / pipeline-config / schedule-config 均必填，必须先 get-pipeline-by-id 回读再改；19 位大整数 ID 字符串传参。

修改集成管道任务配置（调度 / 通道 / 组件）

1. Scenario Description

对**已存在**的 Dataphin 集成管道任务（离线/实时 pipeline）做配置变更，覆盖四类修改：

| 修改类别 | 对应参数 | 典型内容 | |---|---|---| | 调度配置 | `--schedule-config` | cron 表达式、调度周期、重跑策略、优先级、上游依赖、资源组、生效区间 | | 通道配置 | `--settings` | 并发数、脏数据上限、SQL 超时、资源规格、重试次数 | | 组件配置 | `--pipeline-config` | reader/writer 的 PluginConfig（字段映射、过滤条件、分区表达式） | | 基本信息 | `--node-info` / `--comment` | 任务名、备注 |

**核心模式：先查后改、全量回写**——`update-pipeline` 的 `node-info` / `pipeline-config` / `schedule-config` 均为必填，服务端按提交内容整体覆盖。必须先用 `get-pipeline-by-id` 回读当前完整配置，只改目标字段，其余原样回传，否则会**丢失未回传的配置**。

**Architecture**：`Dataphin Tenant + Project + Pipeline（Steps/Hops + ScheduleConfig + Settings）`。

> 💡 新建管道任务请用兄弟 skill `create-pipeline-task`（经套件入口路由加载）；本 skill 只负责修改已有任务。

2. Installation

aliyun plugin install --names aliyun-cli-dataphin-public

（详见 [`references/cli-installation-guide.md`](references/cli-installation-guide.md)）

3. Environment Variables

> 凭证与环境变量由父 skill `alibabacloud-dataphin-skills` 统一声明并预检（父 §3 + §4 Authentication + §8 Step 0，先于路由到本 skill 执行）；本 skill 不重复声明。

4. Authentication

> **Pre-check: Alibaba Cloud Credentials Required** > > **Security Rules:** > - **NEVER** read, echo, or print AK/SK values > - **NEVER** ask the user to input AK/SK directly in the conversation or command line > - **NEVER** use `aliyun configure set` with literal credential values > - **ONLY** use `aliyun configure list` to check credential status > > ```bash > aliyun configure list > ``` > Check the output for a valid profile (AK, STS, or OAuth identity). > > **If no valid profile exists, STOP here.** > 1. Obtain credentials from [Alibaba Cloud Console](https://ram.console.aliyun.com/manage/ak) > 2. Configure credentials **outside of this session** (via `aliyun configure` in terminal or environment variables in shell profile) > 3. Return and re-run after `aliyun configure list` shows a valid profile

**Pre-check: Aliyun CLI >= 3.4.8 required** > Run `aliyun version` to verify >= 3.4.8. If not installed or version too low, > see `references/cli-installation-guide.md` for the OS-specific installation script.

**Pre-check: Aliyun CLI plugin update required** > [MUST] run `aliyun configure set --auto-plugin-install true` to enable automatic plugin installation. > [MUST] run `aliyun plugin update` to ensure that any existing plugins are always up-to-date.

5. RAM Policy

最小权限策略详见 [`../../ram-policies.md`](../../ram-policies.md)。

> **[MUST] Permission Failure Handling:** When any command or API call fails due to permission errors at any point during execution, follow this process: > 1. Read `../../ram-policies.md` to get the full list of permissions required by this SKILL > 2. Use `ram-permission-diagnose` skill to guide the user through requesting the necessary permissions > 3. Pause and wait until the user confirms that the required permissions have been granted

6. Parameter Confirmation

> **IMPORTANT: Parameter Confirmation** — Before executing any command or API call, > ALL user-customizable parameters (e.g., RegionId, instance names, CIDR blocks, > passwords, domain names, resource specifications, etc.) MUST be confirmed with the > user. Do NOT assume or use default values without explicit user approval.

| 参数 | 必填 | 描述 | 默认值 | |---|---|---|---| | `--tenant-id` | 是 | 租户 ID（19 位 snowflake，**字符串传**；多租户共享 endpoint 时必须显式传项目所属租户） | — | | `--project-id` | 是 | 项目 ID | — | | `--context` | 是 | 请求上下文：`--context Env=DEV ProjectId=<project-id>`（Env 取 `DEV`/`PROD`；与 `--project-id` 同时传） | — | | `--pipeline-id` / `--file-id` / `--node-id` | 三选一 | 定位目标管道任务 | — | | `--node-info` | 是 | `{"NodeName":"...","PipelineId":<id>}` | — | | `--pipeline-config` | 是 | Steps/Hops JSON 字符串（未改动也必须完整回传） | — | | `--schedule-config` | 是 | 调度配置 JSON 字符串 | — | | `--settings` | 否 | 通道配置 JSON 字符串（不传可能丢失原配置，建议回传） | — | | `--submit` | 否 | 是否提交（**缺省即提交**；显式传时必须带布尔值 `--submit true|false`，不可裸传） | true |

7. Observability (MUST follow for every aliyun command)

**session-id 由父 skill `alibabacloud-dataphin-skills` 在套件入口加载时生成（32-char 小写 hex），本子 skill 加载时直接继承同一 session-id，不再重新生成。**

**Rule: Every `aliyun` CLI command that calls a cloud API MUST include the `--user-agent` flag.** Local utility commands (e.g. `configure`, `plugin`, `version`) do not support this flag and should be excluded.

--user-agent AlibabaCloud-Agent-Skills/update-pipeline-task/{session-id}

Example (assuming session-id is `a1b2c3d4e5f6a7b8c9d0e1f2a3b4c5d6`):

aliyun dataphin-public get-pipeline-by-id --tenant-id "1234567890123456789" \
  --user-agent AlibabaCloud-Agent-Skills/update-pipeline-task/a1b2c3d4e5f6a7b8c9d0e1f2a3b4c5d6

Do not skip, alter the format, or omit `--user-agent` on any `aliyun` API command invocation.

8. Core Workflow

TENANT_ID="..."          # 19 位字符串
PROJECT_ID="..."
SESSION_ID="<inherited from alibabacloud-dataphin-skills>"

Step 1 · 回读当前完整配置（必做，禁止跳过）

aliyun dataphin-public get-pipeline-by-id \
  --tenant-id "$TENANT_ID" \
  --project-id "$PROJECT_ID" \
  --context Env=DEV ProjectId=$PROJECT_ID \
  --pipeline-id <pipelineId> \
  --user-agent AlibabaCloud-Agent-Skills/update-pipeline-task/$SESSION_ID

• 定位方式三选一：`--pipeline-id`（管道主键）/ `--file-id`（任务文件 ID）/ `--node-id`（调度节点 ID）
• 只知道任务名时：先用 `list-files --category offlinePipeline --directory / --recursive true` 按名称反查 fileId，再用 `--file-id` 查询
• 返回的 `Data.{NodeInfo,PipelineConfig,ScheduleConfig,Settings}` 与 update-pipeline 四个入参一一对应，分别落盘为本地 JSON（如 `current-*.json`），作为回写基线

Step 2 · 局部修改目标字段

只改用户要求的字段，其余**原样保留**。按修改类别