add task

pipelines/cluster-create-dataload.yaml

@@ -0,0 +1,25 @@
+apiVersion: crd.chenshaowen.com/v1
+kind: Pipeline
+metadata:
+  name: cluster-create-dataload
+  namespace: ops-system
+spec:
+  desc: 预热数据集
+  variables:
+    typeRef:
+      value: "cluster"
+      required: true
+    nameRef:
+      required: true
+    namespace:
+      required: true
+      desc: 命名空间
+    dataset:
+      required: true
+      desc: 数据集、存储名字
+    path:
+      required: true
+      desc: 存储路径
+  tasks:
+    - name: 创建数据集预热任务
+      ref: create-dataload

pipelines/cluster-get-dataset-status.yaml

@@ -18,5 +18,5 @@ spec:
       required: true
       desc: 数据集、存储名字
   tasks:
-    - name: 数据集状态
+    - name: 查询数据集状态
       ref: get-dataset-status

tasks/create-dataload.yaml

@@ -0,0 +1,44 @@
+apiVersion: crd.chenshaowen.com/v1
+kind: Task
+metadata:
+  name: create-dataload
+  namespace: ops-system
+spec:
+  desc: create dataload
+  typeRef: cluster
+  nodeName: anymaster
+  variables:
+    namespace:
+      display: namespace
+      required: true
+    dataset:
+      display: dataset
+      desc: dataset name
+    path:
+      display: path
+      desc: path of the dataset
+      required: true
+  steps:
+    - name: create dataload
+      content: |
+        kubectl create -f - <<EOF
+        apiVersion: data.fluid.io/v1alpha1
+        kind: DataLoad
+        metadata:
+          generateName: ${dataset}-
+          namespace: ${namespace}
+        spec:
+          dataset:
+            name: ${dataset}
+            namespace: ${namespace}
+          options:
+            timeout: 48h
+          target:
+          - path: ${path}
+            replicas: 3
+        EOF
+        if [ $? -ne 0 ]; then
+          echo "create dataload failed"
+        else
+          echo "create dataload success"
+        fi