name: 流程定义示例
desc: 这是一个流程定义示例
timeout:
  duration: 10m
  policy: TIME_OUT_WF
input:
- operator:
    options:
    - workflow
    - conductor
    default: workflow
    required: true
owner:
  wechat: replaceme
  chatGroup: replaceme
variables:
  instName: 测试项目
nodes:
- t0:
    type: ASSIGN
    assign:
    - biz:
        projectName: 流程定义示例
    - owner:
        wechat: replaceme
    - variables:
        test: hh
    next: end
    return:
      code: 0

type: timer
expr: 0 15 11 ? * MON,TUE,WED,THU,FRI
actions:
  sw:
    action: START_WORKFLOW
    allowDays: WORKDAY
    args:
      operator: timer
      name: test
      input:
        k1: v1

type: event
event: FiberUpdateUserEvent
actions:
- a1:
    action: RERUN_NODE
    condition: ${event.type == w.v.type}
    args:
      node: t2
      operator: ${event.operator}
- a4:
    action: COMPLETE_NODE
    condition: ${event.operator == w.v.operator}
    args:
      operator: ${event.operator}
      node: ${event.node}
      input:
        k1: v1
      output:
        k1: v2
      status: succeed

name: 调用蓝盾流水线
schedule: {}
args:
  service: trpc.dws.devopsserver.BkHub
  method: StartBuild
  protocol: TRPC
  body:
    projectID: tdcos-templates
    pipelineID: p-4ca6197041984cd98dba3e2b23a4a6c8
    pipelineConfig:
      config:
        project: 蓝盾测试
pollArgs:
  service: trpc.dws.devopsserver.BkHub
  method: GetBuildResult
  protocol: TRPC
  timeoutDuration: 1h
  pollCondition: ${t2.po.data.completed == true}
  successCondition: ${t2.po.data.status == 'SUCCEED'}
  cancelCondition: ${t2.po.data.status == 'CANCELED'}
  body:
    buildID: ${t2.o.data.id}
    outputVariables:
    - publish_date
cancelArgs:
  service: trpc.dws.devopsserver.BkHub
  method: CancelBuild
  protocol: TRPC
  body:
    buildID: ${t2.o.data.id}
type: SERVICE

args:
  body:
    creator: petehuang
    description: testCreateIteration
    enddate: 2022-03-11
    name: test
    startdate: 2022-03-11
    workspace_id: "69991118"
  func: /devops/tapd/createiteration
  protocol: TRPC_HTTP
  service: trpc.dws.devopsserver.TapdHub
name: 创建迭代
type: SERVICE

name: HTTP调用示例
args:
  protocol: HTTP
  method: POST
  url: http://www.fflow.link
  body:
    params:
      width: 100
      height: 100
  headers:
    Accept: application/json
    Content-Type: application/json
type: SERVICE

name: FAAS示例
args:
  protocol: FAAS
  namespace: default
  func: HttpRequestExample
  body:
    user: replaceme
type: service

name: 条件节点
type: switch
switch:
- condition: "${w.i.operator == 'replaceme'}"
  next: case1
- condition: "${w.i.operator == 'replaceme1'}"
  next: case2
next: defaultCase

name: ExclusiveJoin示例
type: exclusive_join

type: transform
output:
  lala: "${w.i.operator}"
next: e2

fork:
- fj1
- fj2

type: join

name: 子流程示例
nodes:
- s1:
    subworkflow: sw1
    args:
      operator: timer
      name: test
      input:
        k1: v1
    type: sub_workflow
subworkflows:
- sw1:
    name: 子流程实例
    desc: 子流程描述示例
    nodes:
    - t1:
        name: 创建群聊
        args:
          protocol: trpc
          service: trpc.dws.chatops.ChatOps
          method: /helper/group/creation
          body:
            name: 子流程群聊示例
            userlist:
            - "${w.i.operator}"
        type: SERVICE

type: assign
name: 设置全局变量
assign:
- biz:
    projectName: 流程定义示例
- owner:
    wechat: replaceme
- variables:
    test: hh

type: wait
wait:
  duration: 10s