工作流的定义包含三部分：

• 工作流全局配置：工作流全局生效的配置项
• 任务模板：节点（子任务）的配置模板，工作流中的每个节点均作为一个自定义训练，任务模板中定义配置信息以及的输入
• 任务编排：通过引用任务模板定义每个节点运行的内容，并编排节点的执行顺序与依赖关系

如下是一个工作流配置yaml的基本结构，其中：

• inputs定义了工作流的全局输入参数
• taskTemplates 定义子任务（节点）的配置，详细参数说明参考自定义训练配置
• tasks中编排了工作流中任务的节点执行顺序与依赖关系，并定义了每个任务节点的输入值

version: v1 
kind: PipelineTemplate  
inputs:
    ...
taskTemplates:
    ...
tasks:
    ...

Hello World: 创建一个单任务工作流

• 定义任务模板

...
taskTemplates:
- name: hello_world_temp
  type: CustomTask
  spec:          
    # 入口命令
    Entrypoint: echo "Hello World!" 
    # 训练框架，支持 TensorFlowPS / PyTorchDDP / MPI / BytePS / Custom
    Framework: Custom                  
    # 镜像 URL 地址：当使用火山引擎镜像或者公网镜像时使用该字段，ImageUrl 优先级高于 Image 字段
    ImageUrl: vemlp-cn-beijing.cr.volces.com/preset-images/python:3.7-ubuntu20.04
    # 队列名称
    ResourceQueueName: <Your Resource Queue Name>
    # 实例配置
    TaskRoleSpecs:                     
    - Flavor: ml.g1ie.large            # 实例规格（Flavor）
      RoleName: worker                 # 角色名称（RoleName）
      RoleReplicas: 1                  # 角色数量（RoleReplicas）
...

• 任务编排

...
tasks:
- name: hello_world                    # 节点名
  taskTemplateName: hello_world_temp # 引用的任务模板名称
...

• 完整工作流YAML

version: v1 
kind: PipelineTemplate    
# 定义工作流中的节点（子任务）模板
taskTemplates:
- name: hello_world_temp
  type: CustomTask
  spec:            
    # 入口命令
    Entrypoint: echo "Hello World!" 
    # 训练框架，支持 TensorFlowPS / PyTorchDDP / MPI / BytePS / Custom
    Framework: Custom                  
    # 镜像 URL 地址：当使用火山引擎镜像或者公网镜像时使用该字段，ImageUrl 优先级高于 Image 字段
    ImageUrl: vemlp-cn-beijing.cr.volces.com/preset-images/python:3.7-ubuntu20.04
    # 队列名称
    ResourceQueueName: <Your Resource Queue Name>
    # 实例配置
    TaskRoleSpecs:                     
    - Flavor: ml.g1ie.large            # 实例规格（Flavor）
      RoleName: worker                 # 角色名称（RoleName）
      RoleReplicas: 1                  # 角色数量（RoleReplicas）
tasks:
- name: hello_world                    # 节点名
  taskTemplateName: hello_world_temp # 引用的任务模板名称

创建任务A串联任务B的线性工作流

• 定义任务模板

...
taskTemplates:
  - name: demo
    type: CustomTask
    spec:
      Entrypoint: echo "Hello Pipeline!" 
      # 训练框架，支持 TensorFlowPS / PyTorchDDP / MPI / BytePS / Custom
      Framework: Custom                  
      # 镜像 URL 地址：当使用火山引擎镜像或者公网镜像时使用该字段，ImageUrl 优先级高于 Image 字段
      ImageUrl: vemlp-cn-beijing.cr.volces.com/preset-images/python:3.7-ubuntu20.04
      # 队列名称
      ResourceQueueName: ldy-test-user0  
      # 实例配置
      TaskRoleSpecs:                     
        - Flavor: ml.g1ie.large# 实例规格（Flavor）
          RoleName: worker     # 角色名称（RoleName）
          RoleReplicas: 1      # 角色数量（RoleReplicas）
...

• 任务编排
  定义每个节点引用的任务模板，以及节点间的依赖关系

...
tasks:
  - name: task_a             
    taskTemplateName: demo # 引用demo中定义的任务配置
  - name: task_b
    taskTemplateName: demo
    dependencies:            # 指定任务上游依赖
    - task_a                 # 依赖 task_a 运行结束
...

• 完整工作流YAML

version: v1 
kind: PipelineTemplate    
# 定义工作流中的节点（子任务）模板
taskTemplates:
- name: demo
  type: CustomTask
  spec:
    Entrypoint: echo "Hello Pipeline!" 
    # 训练框架，支持 TensorFlowPS / PyTorchDDP / MPI / BytePS / Custom
    Framework: Custom                  
    # 镜像 URL 地址：当使用火山引擎镜像或者公网镜像时使用该字段，ImageUrl 优先级高于 Image 字段
    ImageUrl: vemlp-cn-beijing.cr.volces.com/preset-images/python:3.7-ubuntu20.04
    # 队列名称
    ResourceQueueName: ldy-test-user0  
    # 实例配置
    TaskRoleSpecs:                     
    - Flavor: ml.g1ie.large# 实例规格（Flavor）
      RoleName: worker     # 角色名称（RoleName）
      RoleReplicas: 1      # 角色数量（RoleReplicas）
tasks:
- name: task_a             # 节点名
  taskTemplateName: demo # 引用的任务模板名称
- name: task_b
  taskTemplateName: demo
  dependencies:            # 指定任务上游依赖
  - task_a                 # 依赖 task_a 运行结束

配置工作流输入参数，支持在子任务中引用工作流的输入

• 定义全局输入

...
# 定义 Pipeline 的输入参数
inputs:
- name: image_url  # 参数名
  type: string     # 参数类型
  hint: 镜像地址    # 参数描述
  # 参数默认值
  defaultValue: vemlp-cn-beijing.cr.volces.com/preset-images/python:3.7-ubuntu20.04
- name: command
  type: string
  hint: 入口命令
  ...

• 定义任务模板
  在任务模板中定义输入参数

...
taskTemplates:
  ...
  # 定义工作流中的节点（子任务）模板的输入参数
  inputs:
  - name: resource_queue_name # 参数名
    type: string              # 参数类型
    hint: 队列名称             # 参数描述
    defaultValue: <Your Resource Queue Name>    # 参数默认值
  - name: image_url  
    type: string     
    hint: 镜像地址   
  - name: command
    type: string
    hint: 入口命令
  spec:
    ...
    Entrypoint: '{{inputs.command}}'  # 引用模版定义的 name 为 command 的输入参数
    ImageUrl: '{{inputs.image_url}}'
    ResourceQueueName: '{{inputs.resource_queue_name}}'
    ...
    
  ...
  
...

• 任务编排
  • 定义每个节点引用的任务模板，以及节点间的依赖关系
  • 并引用全局输入参数，传入子任务模版所需输入参数

...
tasks:
- name: task_a                  
  taskTemplateName: task_demo 
  inputs:
  - name: image_url
    value: '{{pipeline.inputs.image_url}}' # 引用 Pipeline 定义的 name 为 image_url 的输入参数
  - name: command
    value: '{{pipeline.inputs.command}}'
  # 未声明的输入参数，将使用模板定义的默认值，如 resource_queue_name
- name: task_b
  taskTemplateName: task_demo
  dependencies:                
  - task_a                     
  inputs:
  - name: image_url
    value: '{{pipeline.inputs.image_url}}'
  - name: command
    value: echo "task b!"     # 使用常量 重写模板定义的 name 为 command 的输入参数
  - name: resource_queue_name # 重写模板定义的 name 为 resource_queue_name 输入参数的默认值
    value: 全流量0414
  ...

• 完整工作流YAML

version: v1
kind: PipelineTemplate
# 定义 Pipeline 的输入参数
inputs:
- name: image_url  # 参数名
  type: string     # 参数类型
  hint: 镜像地址    # 参数描述
  # 参数默认值
  defaultValue: vemlp-cn-beijing.cr.volces.com/preset-images/python:3.7-ubuntu20.04
- name: command
  type: string
  hint: 入口命令
taskTemplates:
- name: task_demo
  type: CustomTask
  # 定义工作流中的节点（子任务）模板的输入参数
  inputs:
  - name: resource_queue_name # 参数名
    type: string              # 参数类型
    hint: 队列名称             # 参数描述
    defaultValue: <Your Resource Queue Name>    # 参数默认值
  - name: image_url  
    type: string     
    hint: 镜像地址   
  - name: command
    type: string
    hint: 入口命令
  spec:
    Entrypoint: '{{inputs.command}}'  # 引用模版定义的 name 为 command 的输入参数
    Framework: Custom
    ImageUrl: '{{inputs.image_url}}'
    ResourceQueueName: '{{inputs.resource_queue_name}}'
    TaskRoleSpecs:
    - Flavor: ml.g1ie.large       
      RoleName: worker          
      RoleReplicas: 1           
tasks:
- name: task_a                  
  taskTemplateName: task_demo 
  inputs:
  - name: image_url
    value: '{{pipeline.inputs.image_url}}' # 引用 Pipeline 定义的 name 为 image_url 的输入参数
  - name: command
    value: '{{pipeline.inputs.command}}'
  # 未声明的输入参数，将使用模板定义的默认值，如 resource_queue_name
- name: task_b
  taskTemplateName: task_demo
  dependencies:                
  - task_a                     
  inputs:
  - name: image_url
    value: '{{pipeline.inputs.image_url}}'
  - name: command
    value: echo "task b!"     # 使用常量 重写模板定义的 name 为 command 的输入参数
  - name: resource_queue_name # 重写模板定义的 name 为 resource_queue_name 输入参数的默认值
    value: 全流量0414

创建一个工作流，同时上传本地代码

• 定义任务模板
  在任务模板中定义代码上传配置

...
# 定义工作流中的节点（子任务）模板
taskTemplates:
- name: upload_code
  type: CustomTask
  spec:
    # 待上传代码的本地路径, 如是目录且以 '/' 结尾, 则将该目录下的所有内容上传到 RemoteMountCodePath,
    # 如是目录且不以 '/' 结尾, 则将该目录及该目录下所有内容上传到 RemoteMountCodePath
    UserCodePath: samples/pipeline/code/single_with_upload_code/
    # 使用之前上传的代码快照
    # UserCodePath: tos://ml-platform-auto-created-required-2100000050-cn-guilin-boe/static/customtask/manifest/snapshot_jqsgdgcsc69nvzx8.manifest
    # 上传代码后的路径, 该路径将作为容器中的代码挂载路径
    RemoteMountCodePath: "/root/code"
    ...
  ...
...

• 完整工作流YAML

version: v1
kind: PipelineTemplate
# 定义工作流中的节点（子任务）模板
taskTemplates:
- name: upload_code
  type: CustomTask
  spec:
    # 待上传代码的本地路径, 如是目录且以 '/' 结尾, 则将该目录下的所有内容上传到 RemoteMountCodePath,
    # 如是目录且不以 '/' 结尾, 则将该目录及该目录下所有内容上传到 RemoteMountCodePath
    UserCodePath: run.sh
    # 使用之前上传的代码快照
    # UserCodePath: tos://ml-platform-auto-created-required-2100000050-cn-guilin-boe/static/customtask/manifest/snapshot_jqsgdgcsc69nvzx8.manifest
    # 上传代码后的路径, 该路径将作为容器中的代码挂载路径
    RemoteMountCodePath: "/root/code"
    # 可见范围，支持 Public / Queue / Private
    AccessType: Public
    # 可见用户列表, 注释下方两行可以配置, 注意: 如可见范围为 Private/Public, 则可见用户列表不生效
    # AccessUsers:
    # - "username_a"
    # - "username_b"
    # 入口命令
    Entrypoint: cd /root/code && bash run.sh
    # 训练框架，支持 TensorFlowPS / PyTorchDDP / MPI / BytePS / Custom
    Framework: Custom
    # 镜像 URL 地址：当使用火山引擎镜像或者公网镜像时使用该字段，ImageUrl 优先级高于 Image 字段
    ImageUrl: vemlp-cn-beijing.cr.volces.com/preset-images/python:3.7-ubuntu20.04
    # 队列名称
    ResourceQueueName: <Your Resource Queue Name>
    # 实例配置
    TaskRoleSpecs:
    - Flavor: ml.c1.large              # 实例规格（Flavor）
      RoleName: worker                 # 角色名称（RoleName）
      RoleReplicas: 1                  # 角色数量（RoleReplicas）
tasks:
- name: upload_code                    # 节点名
  taskTemplateName: upload_code      # 引用的任务模板名称

任务编排示例

• 串行： 定义一个包含三个任务节点的工作流，三个任务节点依次串行执行

version: v1 
kind: PipelineTemplate    
# 定义工作流中的节点（子任务）模板
taskTemplates:
- name: demo
  type: CustomTask
  spec:
    ...
tasks:
- name: task_a             
  taskTemplateName: demo 
- name: task_b
  taskTemplateName: demo
  dependencies:            
  - task_a                 
- name: task_c
  taskTemplateName: demo
  dependencies:            
  - task_b                

# +---------+
# |  task_a |
# +----+----+
#      |
# +----v----+
# |  task_b |
# +----+----+
#      |
# +----v----+
# |  task_c |
# +---------+

• 并行：定义一个包含三个任务节点的工作流，三个任务节点并行执行

version: v1 
kind: PipelineTemplate    
# 定义工作流中的节点（子任务）模板
taskTemplates:
- name: demo
  type: CustomTask
  spec:
    ...
tasks:
- name: task_a             
  taskTemplateName: demo 
- name: task_b
  taskTemplateName: demo           
- name: task_c
  taskTemplateName: demo 

# +--------+   +--------+   +--------+
# | task_a |   | task_b |   | task_c |
# +--------+   +--------+   +--------+

• 菱形：定义一个包含4个节点的菱形工作流

version: v1 
kind: PipelineTemplate    
# 定义工作流中的节点（子任务）模板
taskTemplates:
- name: demo
  type: CustomTask
  spec:
    ...
tasks:
- name: task_a             
  taskTemplateName: demo 
- name: task_b
  taskTemplateName: demo    
  dependencies:            
  - task_a                 
- name: task_c
  taskTemplateName: demo
  dependencies:            
  - task_a           
- name: task_d
  taskTemplateName: demo
  dependencies:            
  - task_b
  - task_c          

#       +--------+   
#       | task_a |  
#       +--------+   
#        /      \
# +--------+   +--------+
# | task_b |   | task_c |
# +--------+   +--------+
#        \      /
#       +--------+   
#       | task_d |  
#       +--------+